【JDK8 新特性 6】收集Stream流中的结果

简介: 对流操作完成之后,如果需要将流的结果保存到数组或集合中,可以收集流中的数。

对流操作完成之后,如果需要将流的结果保存到数组或集合中,可以收集流中的数。

1、Stream流中的结果到集合中

Stream流提供 collect 方法,其参数需要一个 java.util.stream.Collector<T,A, R> 接口对象来指定收集到哪种集合中。
java.util.stream.Collectors 类提供一些方法,可以作为 Collector`接口的实例。
23.png
下面是这两个方法的基本使用代码:
24.png

2、Stream流中的结果到数组中

Stream提供 toArray 方法来将结果放到一个数组中,返回值类型是Object[]的。
25.png
基本使用如下
26.png

3、对流中数据进行聚合计算

当我们使用Stream流处理数据后,可以像数据库的聚合函数一样对某个字段进行操作。
比如获取最大值,获取最小值求总和平均值统计数量

3.1 获取最大值

    public static void main(String[] args) {

        Stream<Person> stream = Stream.of(new Person("小明", 19),
                new Person("小红", 18),
                new Person("小黄", 17));

        //最大值
        Optional<Person> collect = stream.collect(Collectors.maxBy((o1, o2) -> o1.getAge() - o2.getAge()));
        System.out.println("年龄最大的是:"+collect.get().getName());
    }

3.2 获取最小值

    public static void main(String[] args) {

        Stream<Person> stream = Stream.of(new Person("小明", 19),
                new Person("小红", 18),
                new Person("小黄", 17));

        //最小值
        Optional<Person> collect = stream.collect(Collectors.minBy((o1, o2) -> o1.getAge() - o2.getAge()));
        System.out.println("年龄最小的是:"+collect.get().getName());
    }

3.3 求总和

 Stream<Person> stream = Stream.of(new Person("小明", 19),
                new Person("小红", 18),
                new Person("小黄", 17));

        //总和
        int sum = stream.collect(Collectors.summingInt(s -> s.getAge()));
        System.out.println("年龄总和:" + sum);

3.4 平均值

 Stream<Person> stream = Stream.of(new Person("小明", 19),
                new Person("小红", 18),
                new Person("小黄", 17));

        //平均
        double avg = stream.collect(Collectors.averagingInt(s -> s.getAge()));
        System.out.println("平均年龄:" + avg);

3.5 统计数量


        Stream<Person> stream = Stream.of(new Person("小明", 19),
                new Person("小红", 18),
                new Person("小黄", 17));

        //统计数
        double cunt = stream.collect(Collectors.counting());
        System.out.println("统计数:" + cunt);

4、 对流中数据进行分组

当我们使用Stream流处理数据后,可以根据某个属性将数据分组:
27.png

5、对流中数据进行多级分组

我们还可以对数据进行多级分组:
30.png

6、对流中数据进行多级分区

Collectors.partitioningBy 会根据值是否为true,把集合分割为两个列表,一个true列表,一个false列表。
28.png

7、对流中数据进行拼接

Collectors.joining 会根据指定的连接符,将所有元素连接成一个字符串。
31.png

8、总结

  1. 到集合中: Collectors.toList()/Collectors.toSet()/Collectors.toCollection() 。
  2. 到数组中: toArray()/toArray(int[]::new) 。
  3. 聚合计算: Collectors.maxBy/Collectors.minBy/Collectors.counting/Collectors.summingInt/Collectors.averagingInt 。
  4. 分组: Collectors.groupingBy 。
  5. 分区: Collectors.partitionBy 。
  6. 拼接: Collectors.joinging。
相关文章
|
2月前
|
容器
jdk8新特性-详情查看文档
jdk8新特性-详情查看文档
45 3
|
1月前
|
存储 安全 Java
JDK1.8 新的特性
JDK1.8 新的特性
19 0
|
2月前
|
编解码 安全 Java
jdk8新特性-接口和日期处理
jdk8新特性-接口和日期处理
|
3月前
|
API
JDK8的stream有求和方法吗?
【8月更文挑战第20天】JDK8的stream有求和方法吗?
127 3
|
3月前
|
Java API
JDK8到JDK25版本升级的新特性问题之使用Collectors.teeing()来计算一个列表中学生的平均分和总分如何操作
JDK8到JDK25版本升级的新特性问题之使用Collectors.teeing()来计算一个列表中学生的平均分和总分如何操作
|
3月前
|
Java API Apache
JDK8到JDK24版本升级的新特性问题之在Java中,HttpURLConnection有什么局限性,如何解决
JDK8到JDK24版本升级的新特性问题之在Java中,HttpURLConnection有什么局限性,如何解决
|
3月前
|
Oracle Java 关系型数据库
JDK8到JDK29版本升级的新特性问题之未来JDK的升级是否会成为必然趋势,如何理解
JDK8到JDK29版本升级的新特性问题之未来JDK的升级是否会成为必然趋势,如何理解
|
3月前
|
Oracle 安全 Java
JDK8到JDK28版本升级的新特性问题之在Java 15及以后的版本中,密封类和密封接口是怎么工作的
JDK8到JDK28版本升级的新特性问题之在Java 15及以后的版本中,密封类和密封接口是怎么工作的
|
3月前
|
Java API 开发者
JDK8到JDK17版本升级的新特性问题之SpringBoot选择JDK17作为最小支持的Java lts版本意味着什么
JDK8到JDK17版本升级的新特性问题之SpringBoot选择JDK17作为最小支持的Java lts版本意味着什么
128 0
JDK8到JDK17版本升级的新特性问题之SpringBoot选择JDK17作为最小支持的Java lts版本意味着什么
|
2月前
|
Java 编译器 API
JDK8新特性--lambda表达式
JDK8的Lambda表达式是Java语言的一大进步。它为Java程序提供了更多的编程方式,让代码更加简洁,也让函数式编程的概念在Java中得到了体现。Lambda表达式与Java 8的其他新特性,如Stream API、新的日期时间API一起,极大地提高了Java编程的效率和乐趣。随着时间的流逝,Java开发者对这些特性的理解和应用将会越来越深入,进一步推动Java语言和应用程序的发展。
14 0