ApacheFlink-如何使用groupby聚合字符串列表
创始人
2024-09-05 19:00:52
0
  1. 定义一个字符串列表类型的Tuple类:
public class StringListTuple {
    public String key;
    public List value;

    public StringListTuple() {}

    public StringListTuple(String key, List value) {
        this.key = key;
        this.value = value;
    }

    public static StringListTuple of(String key, List value) {
        return new StringListTuple(key, value);
    }
}
  1. 使用group by和reduce进行聚合:
DataStream> dataStream = ...;

DataStream resultStream = dataStream
  .keyBy(value -> value.f0)
  .reduce((value1, value2) -> {
      List list = new ArrayList<>();
      list.addAll(value1.f1);
      list.addAll(value2.f1);
      return Tuple2.of(value1.f0, list);
  })
  .map(value -> StringListTuple.of(value.f0, value.f1));
  1. 将结果转换为字符串:
DataStream stringResult = resultStream
  .map(value -> value.key + ": " + String.join(", ", value.value));

相关内容

热门资讯

技术分享!广东闲来辅助神器免费... 技术分享!广东闲来辅助神器免费版,wpk官网下载链接,黑科技教程(有挂头条);1、点击下载安装,广东...
科技揭秘!福建相约13水外,线... 科技揭秘!福建相约13水外,线上德州的辅助器是什么,曝光教程(有挂秘笈)是一款可以让一直输的玩家,快...
一分钟了解!土豪联盟辅助器,w... 您好,土豪联盟辅助器这款游戏可以开挂的,确实是有挂的,需要了解加微【136704302】很多玩家在这...
玩家攻略推荐!吉祥填大坑有插件... 玩家攻略推荐!吉祥填大坑有插件吗,wpk辅助,黑科技教程(有挂方法);吉祥填大坑有插件吗AI智能教程...
教学盘点!来来拼十软件脚本,h... 教学盘点!来来拼十软件脚本,hhpoker俱乐部是干嘛的,曝光教程(有挂实锤);来来拼十软件脚本是一...
科技通报!微信闲来神器软件下载... 科技通报!微信闲来神器软件下载,aapoker插件下载,介绍教程(有挂透明挂),微信闲来神器软件下载...
总算明白!七千在线辅助,德州来... 总算明白!七千在线辅助,德州来玩辅助器,专业教程(有挂工具);1、总算明白!七千在线辅助,德州来玩辅...
分享给玩家!三哥玩app辅助,... 分享给玩家!三哥玩app辅助,哈糖大菠萝辅助器,2025新版教程(有挂解惑),哈糖大菠萝辅助是用手机...
盘点几款!欢乐对决脚本,wep... 您好,欢乐对决脚本这款游戏可以开挂的,确实是有挂的,需要了解加微【136704302】很多玩家在这款...
技巧知识分享!海米大厅辅助,a... 技巧知识分享!海米大厅辅助,aapoker怎么拿好牌,2025新版总结(详细教程);海米大厅辅助软件...