tongchenkeji 发表于：2023-3-15 11:25:580次点击 已关注取消关注 关注 私信 Flink怎么实现按照第一个key分组？[阿里云实时计算 Flink版] 暂停朗读为您朗读 Flink怎么实现按照第一个key分组？ 「点点赞赏，手留余香」 赞赏 还没有人赞赏，快来当第一个赞赏的人吧！ 海报 实时计算Flink版# 实时计算 Flink版3179# 流计算2236
认真学习的heartAM 2023-11-27 18:42:39 1 在Flink中，按照第一个key分组可以通过groupBy()函数实现。例如，假设我们有一个Tuple2类型的数据集，其中第一个元素为字符串类型，第二个元素为整型类型，我们想要按照第一个元素进行分组。
665661AM 2023-11-27 18:42:39 2 你前面返回的是jsonString， 那你们你在keyby里面就需要把jsonstring的数据取出来。或者 你前面map用javaBean 去返回，然后你再keyBy 里面就可以使用 get方法 获取你需要的字段。——该回答整理自钉群“【③群】Apache Flink China社区”
在Flink中，按照第一个key分组可以通过groupBy()函数实现。例如，假设我们有一个Tuple2类型的数据集，其中第一个元素为字符串类型，第二个元素为整型类型，我们想要按照第一个元素进行分组。
你前面返回的是jsonString， 那你们你在keyby里面就需要把jsonstring的数据取出来。或者 你前面map用javaBean 去返回，然后你再keyBy 里面就可以使用 get方法 获取你需要的字段。——该回答整理自钉群“【③群】Apache Flink China社区”