开发者社区 问答 正文

pyflink Table object如何打印出其中内容方便调试

您好,我使用pyflink时的代码如下,有如下问题:

source = st_env.from_path('source') #st_env是StreamTableEnvironment,source是kafka源端 #udf1 (input_types =DataTypes.STRING(), result_type = DataTypes.BOOLEAN()) table = source.select("msg").where(udf1(msg)=True)

这样单步调试print(table)出来的结果是<pyflink.table.table.Table object at 0x7f888fb2cef0> pyflink有没有将Table转化成可打印格式的方法 希望您们能够给予解答!感谢! *来自志愿者整理的flink邮件归档

展开
收起
毛毛虫雨 2021-12-07 11:59:44 262 分享 版权
0 条回答
写回答
取消 提交回答