tongchenkeji 发表于：2023-3-15 11:28:210次点击 已关注取消关注 关注 私信 Flink这上一条json和下一条json放在一起怎么做比较的？[阿里云实时计算 Flink版] 暂停朗读为您朗读 Flink这上一条json和下一条json放在一起怎么做比较的？ 「点点赞赏，手留余香」 赞赏 还没有人赞赏，快来当第一个赞赏的人吧！ 海报 实时计算Flink版# JSON177# 实时计算 Flink版3179# 数据格式216# 流计算2236
665661AM 2023-11-27 18:44:22 2 keyby之后 用process 函数， 用mapstate 来存储先到数据，然后再判断后到数据的op，最后拼接起来输出，最后删除当前key 对应的数据。——该回答整理自钉群“【③群】Apache Flink China社区”
可以使用Flink的ProcessFunction
keyby之后 用process 函数， 用mapstate 来存储先到数据，然后再判断后到数据的op，最后拼接起来输出，最后删除当前key 对应的数据。——该回答整理自钉群“【③群】Apache Flink China社区”