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

回复