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