Pyflink 在 Jupyter Notebook 中查看数据，如 Head/Show in pandas/pyspark

Question

我是 PyFlink 的新手，正在努力学习。我将 pyflink 与 jupyter Notebook 一起使用并执行了一些基本操作。因此，当我执行某些操作时，它 return 内存中的一个 table 位置，如“。要查看数据，我需要调用 to_pandas() 方法。是可以在不调用 to_pandas() 的情况下查看数据。Pyflink 中是否有任何可用的方法来查看已处理的数据。例如 pandas 中的 head 或 pyspark 中的 show/display。

谢谢

Answer 1

可以参考pyflink table api https://nightlies.apache.org/flink/flink-docs-master/docs/dev/python/table/intro_to_table_api/

也许你可以使用execute或execute_sql获取TableResult，并在TableResult

中使用collect或print api