开发者社区> 问答> 正文

关于flinkstreaing 中sql聚合结果后的撤回流,过程数据处理问题

用flink接受kafka解析json进行内部表数据聚合
实现主要代码如下:
image
结果:
image
想要聚合后的结果,不想输出过程数据,请问这里应该如何处理,用timewindow没有效果,烦请指教,初学者,如果可以,烦请指导代码。多谢

展开
收起
飘渺の混沌 2018-11-13 14:03:56 3580 0
2 条回答
写回答
取消 提交回答
问答排行榜
最热
最新

相关电子书

更多
SQL Server 2017 立即下载
GeoMesa on Spark SQL 立即下载
原生SQL on Hadoop引擎- Apache HAWQ 2.x最新技术解密malili 立即下载