java8 stream自定义分组求和并排序

    public static void main(String[] args) {
        List<GroupDetailDTO> list = new ArrayList<>();
        GroupDetailDTO dto1 = new GroupDetailDTO();
        dto1.setHeadsetId(1);
        dto1.setTime("2020-01-03");
        dto1.setActConcreteTime("a");
        dto1.setPlayed(1);
        list.add(dto1);

        GroupDetailDTO dto2 = new GroupDetailDTO();
        dto2.setHeadsetId(1);
        dto2.setTime("2020-01-01");
        dto2.setActConcreteTime("b");
        dto2.setPlayed(1);
        list.add(dto2);

        GroupDetailDTO dto3 = new GroupDetailDTO();
        dto3.setHeadsetId(1);
        dto3.setTime("2020-01-02");
        dto3.setActConcreteTime("c");
        dto3.setPlayed(1);
        list.add(dto3);

        GroupDetailDTO dto4 = new GroupDetailDTO();
        dto4.setHeadsetId(2);
        dto4.setTime("2020-01-01");
        dto4.setActConcreteTime("d");
        dto4.setPlayed(4);
        list.add(dto4);

        Map<GroupDetailDTO, Integer> collect = list.stream().collect(Collectors.groupingBy(o -> new GroupDetailDTO(o.getHeadsetId(), o.getTime()), TreeMap::new, Collectors.summingInt(o -> o.getPlayed())));
        collect.forEach((k, v) -> {
            System.out.println(k + "@@@" + v);
        });
    }
@Data
public class GroupDetailDTO implements Comparable<GroupDetailDTO> {
    private Integer headsetId;
    private String actConcreteTime;
    private String time;
    private Integer played;

    public GroupDetailDTO() {
    }

    public GroupDetailDTO(Integer headsetId, String time) {
        this.headsetId = headsetId;
        this.time = time;
    }

    @Override
    public int compareTo(GroupDetailDTO o) {
        String a = this.headsetId + "|" + this.getTime();
        String b = o.getHeadsetId() + "|" + o.getTime();
        return a.compareTo(b);
//        return this.getTime().compareTo(o.gtTime());
    }
}

结果:

上述代码实现对对象GroupDetailDTO按设备和时间分组求played的和,并且按时间排序了。当初想着既然是按时间排序那么compareTo方法直接使用
return this.getTime().compareTo(o.getTime());
但是结果不正确

分析:分组求和时如果使用了排序,那么分组时对相同属性的合并将直接根据compareTo返回的结果合并对象,所以如果用上述方法将产生相同的时间直接合并,而不是new GroupDetailDTO(o.getHeadsetId(), o.getTime())里面的两个属性都相同才合并。

原文地址:https://www.cnblogs.com/shuangyueliao/p/12231703.html

时间: 2024-11-10 17:56:28

java8 stream自定义分组求和并排序的相关文章

java8 stream流操作

Stream 在对流进行处理时,不同的流操作以级联的方式形成处理流水线.一个流水线由一个源(source),0 到多个中间操作(intermediate operation)和一个终结操作(terminal operation)完成. 源:源是流中元素的来源.Java 提供了很多内置的源,包括数组.集合.生成函数和 I/O 通道等. 中间操作:中间操作在一个流上进行操作,返回结果是一个新的流.这些操作是延迟执行的. 终结操作:终结操作遍历流来产生一个结果或是副作用.在一个流上执行终结操作之后,该

【转】Java8 Stream 流详解

  当我第一次阅读 Java8 中的 Stream API 时,说实话,我非常困惑,因为它的名字听起来与 Java I0 框架中的 InputStream 和 OutputStream 非常类似.但是实际上,它们完全是不同的东西. Java8 Stream 使用的是函数式编程模式,如同它的名字一样,它可以被用来对集合进行链状流式的操作. 本文就将带着你如何使用 Java 8 不同类型的 Stream 操作.同时您还将了解流的处理顺序,以及不同顺序的流操作是如何影响运行时性能的. 我们还将学习终端

Hadoop mapreduce自定义分组RawComparator

本文发表于本人博客. 今天接着上次[Hadoop mapreduce自定义排序WritableComparable]文章写,按照顺序那么这次应该是讲解自定义分组如何实现,关于操作顺序在这里不多说了,需要了解的可以看看我在博客园的评论,现在开始. 首先我们查看下Job这个类,发现有setGroupingComparatorClass()这个方法,具体源码如下: /** * Define the comparator that controls which keys are grouped toge

MapReduce自定义分组Group

一:背景 在上一篇文章中我们可以对两列数据进行排序,即完成了当第一列相同时第二列数据升序排列的功能,现在我们需要进一步完善一个功能,那就是当第一列相同时求出第二列的最小值或最大值,Hadoop提供了自定义分组的功能,可以满足我们的需求. 二:技术实现 我们先来看看需求 #当第一列不相等时,第一列按升序排列,当第一列相等时,求出对应第二列的最小值 [java] view plain copy 3   3 3   2 3   1 2   2 2   1 1   1 输出结果应该是: [java] v

Hadoop之--&gt;自定义分组 RawComparator

data: 3 33 23 22 22 11 1 --------------------- 需求: 1 12 23 3 当第一列相同时候要第二列的最小值 package group; import java.io.DataInput; import java.io.DataOutput; import java.io.IOException; import java.net.URI; import org.apache.hadoop.conf.Configuration; import org

自定义分组

job.setGroupingComparatorClass(MyGroupingComparator.class); //按照第一列进行分组,然后找出每个分组中的第二列中的最小值 为什么要自定义分组? 业务要求分组是按照第一列分组,但是NewK2的比较规则决定了不能按照第一列分.只能自定义分组比较器. 1 package group; 2 3 import java.io.DataInput; 4 import java.io.DataOutput; 5 import java.io.IOEx

Hadoop之——自定义分组比较器实现分组功能

转载请注明出处:http://blog.csdn.net/l1028386804/article/details/46287985 不多说,直接上代码,大家都懂得 1.Mapper类的实现 /** * Mapper类的实现 * @author liuyazhuang * */ static class MyMapper extends Mapper<LongWritable, Text, NewK2, LongWritable>{ protected void map(LongWritable

何用Java8 Stream API进行数据抽取与收集

上一篇中我们通过一个实例看到了Java8 Stream API 相较于传统的的Java 集合操作的简洁与优势,本篇我们依然借助于一个实际的例子来看看Java8 Stream API 如何抽取及收集数据. 备注:上一篇内容:如何用Java8 Stream API找到心仪的女朋友 ## 目标&背景 我们以"处理订单数据"为例,假设我们的应用是一个分布式应用,有"订单应用","物流应用","商品应用"等都是独立的服务.本次我

对NSArray中自定义的对象进行排序

本文译自How to sort NSArray with custom objects. 我们开发的每个程序都会使用到一些数据,而这些数据一般被封装在一个自定义的类中.例如一个音乐程序可能会有一个Song类,聊天程序则又一个Friend类,点菜程序会有一个Recipe类等.有时候我们希望在程序中显示的列表数据是按照一定顺序进行排列的,本文我们就来看看在iOS中有哪些方法可以对NSArray中的对象进行排序.下面是目录: 小引 使用NSComparator进行排序 使用NSDescriptor进行