开发者社区> 问答> 正文

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:16 277 0
0 条回答
写回答
取消 提交回答
问答排行榜
最热
最新

相关电子书

更多
成功案例-Par...[幸运杰哥].1512720360.pdf 立即下载
数据采集:日志数...[jing.luojing].1477375627.pdf 立即下载
Java8简明教...[fredwong].1494561200.pdf 立即下载

相关实验场景

更多