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