pyflink 有没有方便的print方式？例如java api中的 .print() ?

[肖越]

最近在尝试 pyflink 功能，只查到了定义connector 的输出方法，例如：
sink_ddl = '''
            CREATE TABLE print_sink (
                        ID DOUBLE,
                        NAME STRING
                    ) WITH (
                      'connector' = 'print'
                    )
        '''
每次都要事先定义好要输出的表格格式，是否有更加方便的输出方法？

[Dian Fu]

可以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，肖越 <[hidden email]> 写道：
>
> 最近在尝试 pyflink 功能，只查到了定义connector 的输出方法，例如：
> sink_ddl = '''
>            CREATE TABLE print_sink (
>                        ID DOUBLE,
>                        NAME STRING
>                    ) WITH (
>                      'connector' = 'print'
>                    )
>        '''
> 每次都要事先定义好要输出的表格格式，是否有更加方便的输出方法？

[huang huang]

print(page_turn.to_pandas())

> 可以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  [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  &gt; 在 2020年12月17日，下午2:47，肖越  写道： &gt; &gt; 最近在尝试 pyflink 功能，只查到了定义connector 的输出方法，例如： &gt; sink_ddl = ''' &gt; CREATE TABLE print_sink ( &gt; ID DOUBLE, &gt; NAME STRING &gt; ) WITH ( &gt; 'connector' = 'print' &gt; ) &gt; ''' &gt; 每次都要事先定义好要输出的表格格式，是否有更加方便的输出方法？