【发布时间】:2022-01-31 10:51:45
【问题描述】:
我是 PyFlink 的新手,正在努力学习。我正在使用带有 jupyter Notebook 的 pyflink 并执行一些基本操作。因此,当我执行某些操作时,它会在内存中返回一个表位置,例如“
【问题讨论】:
标签: jupyter-notebook apache-flink flink-sql pyflink
我是 PyFlink 的新手,正在努力学习。我正在使用带有 jupyter Notebook 的 pyflink 并执行一些基本操作。因此,当我执行某些操作时,它会在内存中返回一个表位置,例如“
【问题讨论】:
标签: jupyter-notebook apache-flink flink-sql pyflink
可以参考pyflink table apihttps://nightlies.apache.org/flink/flink-docs-master/docs/dev/python/table/intro_to_table_api/
可能你可以使用execute或execute_sql来获取TableResult,并在TableResult中使用collect或print api
【讨论】: