对流操作完成之后,如果需要将流的结果保存到数组或集合中,可以收集流中的数。
1、Stream流中的结果到集合中
Stream流提供 collect 方法,其参数需要一个 java.util.stream.Collector<T,A, R> 接口对象来指定收集到哪种集合中。
java.util.stream.Collectors 类提供一些方法,可以作为 Collector`接口的实例。
下面是这两个方法的基本使用代码:
2、Stream流中的结果到数组中
Stream提供 toArray 方法来将结果放到一个数组中,返回值类型是Object[]的。
基本使用如下
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流处理数据后,可以根据某个属性将数据分组:
5、对流中数据进行多级分组
我们还可以对数据进行多级分组:
6、对流中数据进行多级分区
Collectors.partitioningBy 会根据值是否为true,把集合分割为两个列表,一个true列表,一个false列表。
7、对流中数据进行拼接
Collectors.joining 会根据指定的连接符,将所有元素连接成一个字符串。
8、总结
- 到集合中: Collectors.toList()/Collectors.toSet()/Collectors.toCollection() 。
- 到数组中: toArray()/toArray(int[]::new) 。
- 聚合计算: Collectors.maxBy/Collectors.minBy/Collectors.counting/Collectors.summingInt/Collectors.averagingInt 。
- 分组: Collectors.groupingBy 。
- 分区: Collectors.partitionBy 。
- 拼接: Collectors.joinging。