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

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


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

2020-12-16 文章 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
 

[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
 



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



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

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