Collectors.groupingBy分组后乱序问题

简介: Collectors.groupingBy分组后乱序问题

问题描述:

当我们对List根据时间排序,然后根据某个字段分组后,会产生乱序的问题。

解决办法:

因为Collectors.groupingBy分组后默认返回HashMap类型,我们修改为LinkedHashMap即可。


Collectors.groupingBy部分源码:


//一个参数 classifier
public static <T, K> Collector<T, ?, Map<K, List<T>>>
groupingBy(Function<? super T, ? extends K> classifier) {
    return groupingBy(classifier, toList());
}
//两个参数 classifier 和 downstream
public static <T, K, A, D>
    Collector<T, ?, Map<K, D>> groupingBy(Function<? super T, ? extends K> classifier,
                                          Collector<? super T, A, D> downstream) {
    return groupingBy(classifier, HashMap::new, downstream);
}
//三个参数 classifier 和 mapFactory 和 downstream
public static <T, K, D, A, M extends Map<K, D>>
    Collector<T, ?, M> groupingBy(Function<? super T, ? extends K> classifier,
                                  Supplier<M> mapFactory,
                                  Collector<? super T, A, D> downstream) {..}

通过源码可以看到,我们可以上传三个参数,分别是:

classifier:按照什么分组

mapFactory:最后的结果返回的容器

downstream:收集分类的结果的收集器

当我们只上传一个参数后,默认第二个参数downstream是HashMap::new,也就是返回结果用HashMap存储,我们想返回HashMap就需要调用三个参数的方法,自定义downstream为LinkedHashMap::new即可。


样例:


LinkedHashMap<String,List<ProcessDetails>> resultSort;
//根据开始日期排序, groupBy字段分组返回类型修改为LinkedHashMap,否则乱序
resultSort = result
        .stream()
        .sorted(Comparator.comparing(ProcessDetails::getBeginTime))
        .collect(Collectors.groupingBy(ProcessDetails::getGroupBy,LinkedHashMap::new,Collectors.toList()));

以上就是Collectors.groupingBy分组后乱序问题的全部内容

相关文章
|
消息中间件 存储 安全
【深入浅出RocketMQ原理及实战】「底层原理挖掘系列」透彻剖析贯穿RocketMQ的消息顺序消费和并发消费机制体系的原理分析
【深入浅出RocketMQ原理及实战】「底层原理挖掘系列」透彻剖析贯穿RocketMQ的消息顺序消费和并发消费机制体系的原理分析
548 0
|
缓存 NoSQL Java
什么是缓存?如何在 Spring Boot 中使用缓存框架
什么是缓存?如何在 Spring Boot 中使用缓存框架
840 0
|
UED
使echarts图例legend只选中一个(selectedMode)
本文介绍了如何在ECharts图表中设置图例(legend)的选中模式为单选('single'),以确保在有多个图例时,用户只能选择一个图例项进行展示,从而提升图表的可读性和用户体验。
1538 1
使echarts图例legend只选中一个(selectedMode)
|
Oracle NoSQL 关系型数据库
实时计算 Flink版操作报错合集之报错ClassCastException异常如何解决
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
537 0
|
SQL Java 数据库连接
MyBatis SQL 批量更新(代码➕案例)
MyBatis SQL 批量更新(代码➕案例)
1420 0
|
消息中间件 Kafka API
【Kafka】kafka 如何不消费重复数据?
【4月更文挑战第7天】【Kafka】kafka 如何不消费重复数据?
|
JSON 关系型数据库 MySQL
Mysql中JSON操作函数JSON_EXTRACT()
Mysql中JSON操作函数JSON_EXTRACT()
命令行下使用javac编译文件时出现 错误: 编码 GBK 的不可映射字符
命令行下使用javac编译文件时出现 错误: 编码 GBK 的不可映射字符
566 0
|
缓存 Linux 虚拟化
Linux下top命令指标说明
Linux下top命令指标说明
1218 0
|
Java API 开发者