可以collect到client端[1],或者可以看看另外几种方式[2]:

[1] 
https://ci.apache.org/projects/flink/flink-docs-release-1.12/api/python/pyflink.table.html#pyflink.table.TableResult.collect
 
<https://ci.apache.org/projects/flink/flink-docs-release-1.12/api/python/pyflink.table.html#pyflink.table.TableResult.collect>
[2] 
https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/python/table-api-users-guide/intro_to_table_api.html#emit-results
 
<https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/python/table-api-users-guide/intro_to_table_api.html#emit-results>


> 在 2020年12月17日,下午2:47,肖越 <[email protected]> 写道:
> 
> 最近在尝试 pyflink 功能,只查到了定义connector 的输出方法,例如:
> sink_ddl = '''
>            CREATE TABLE print_sink (
>                        ID DOUBLE,
>                        NAME STRING
>                    ) WITH (
>                      'connector' = 'print'
>                    )
>        '''
> 每次都要事先定义好要输出的表格格式,是否有更加方便的输出方法?

回复