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));

相关内容

热门资讯

玩家必看分享!开心十三张有没有... 玩家必看分享!开心十三张有没有挂,wepoker开脚本视频,AA德州教程(有挂方法);开心十三张有没...
9分钟了解!小程序游戏修改器辅... 【福星临门,好运相随】;9分钟了解!小程序游戏修改器辅助,哈糖大菠萝有挂吗,安装教程(真的有挂);暗...
专业讨论!九九联盟辅助,德州局... 专业讨论!九九联盟辅助,德州局HHpoker透视脚本,技巧教程(有挂技巧);专业讨论!九九联盟辅助,...
揭秘真相!荆州晃晃麻将圣盛辅助... 揭秘真相!荆州晃晃麻将圣盛辅助,哈糖大菠萝能开挂吗,软件教程(讲解有挂);揭秘真相!荆州晃晃麻将圣盛...
我来教大家!牵手辅助神器下载,... 我来教大家!牵手辅助神器下载,竞技联盟透视插件,科技教程(的确有挂);大家肯定在之前牵手辅助神器下载...
技术分享!威信茶馆透视挂,云扑... 技术分享!威信茶馆透视挂,云扑克有透视吗,辅助教程(有挂方略)是一款可以让一直输的玩家,快速成为一个...
一分钟教你!潮友辅助开挂,wp... 一分钟教你!潮友辅助开挂,wpk系统是否存在作弊行为,攻略教程(有挂技巧);潮友辅助开挂软件透明挂是...
玩家必看秘籍!奇迹陕西靖边打锅... 玩家必看秘籍!奇迹陕西靖边打锅子辅助,wpk透视辅助靠谱吗,教你攻略(有挂详细)是一款可以让一直输的...
科技通报!七千在线辅助,德州之... 科技通报!七千在线辅助,德州之星扫描器,教你攻略(有挂解密);1、点击下载安装,七千在线辅助插件透视...
新手必备!欢乐情怀辅助器,红龙... 新手必备!欢乐情怀辅助器,红龙poker作弊指令,微扑克教程(有挂解惑);欢乐情怀辅助器软件透明挂是...