Java9 Stream Collectors新增功能(小结)

2024-03-28 15:00:36

Java 9 Stream Collectors新增功能

Java 8 引入Collectors，用于累加输入元素至可变的容器如，Map、List以及Set。本文看看Java 9 新增的两个Collectors：Collectors.filtering 和 Collectors.flatMapping，主要用于和 Collectors.groupingBy 一起提供智能的元素集合.

Collectors.filtering方法

Collectors.filtering方法类似于Stream filter()方法，后者用于过滤输入元素，但两者的使用场景不同。Stream filter()在stream链接方法中使用，而Collectors.filtering方法被设计和 groupingBy一起使用。

Stream filter()首先过滤元素，然后再分组。被过滤的值被丢弃无法被追溯跟踪。如果需要跟踪需要先分组然后再过滤，这正是 Collectors.filtering能做的。

Collectors.filtering带函数参数用于过滤输入参数，然后收集过滤元素：

@Test
public void givenList_whenSatifyPredicate_thenMapValueWithOccurences() {

List<Integer> numbers = List.of(1, 2, 3, 5, 5);

Map<Integer, Long> result = numbers.stream()
 .filter(val -> val > 3)
 .collect(Collectors.groupingBy(i -> i, Collectors.counting()));

assertEquals(1, result.size());

result = numbers.stream()
 .collect(Collectors.groupingBy(i -> i,
  Collectors.filtering(val -> val > 3, Collectors.counting())));

assertEquals(4, result.size());
}

Collectors.flatMapping方法

Collectors.flatMapping类似于Collectors.mapping 方法，但粒度更细。两者都带一个函数和一个收集器参数用于收集元素，但flatMapping函数接收元素流，然后通过收集器进行累积操作。首先我们看模型类：

class Blog {

private String authorName;
private List<String> comments = new ArrayList<>();

public Blog(String authorName, String ... comment){
  this.authorName = authorName;
  comments.addAll(Arrays.asList(comment));
}

public String getAuthorName(){
  return this.authorName;
}

public List<String> getComments(){
  return comments;
}
}

Collectors.flatMapping 方法跳过中间集合，直接写至单个有Collectors.groupingBy定义的组映射容器中：

@Test
public void givenListOfBlogs_whenAuthorName_thenMapAuthorWithComments() {

Blog blog1 = new Blog("1", "Nice", "Very Nice");
Blog blog2 = new Blog("2", "Disappointing", "Ok", "Could be better");
List<Blog> blogs = List.of(blog1, blog2);

Map<String, List<List<String>>> authorComments1 = blogs.stream()
 .collect(Collectors.groupingBy(Blog::getAuthorName,
  Collectors.mapping(Blog::getComments, Collectors.toList())));

assertEquals(2, authorComments1.size());
assertEquals(2, authorComments1.get("1").get(0).size());
assertEquals(3, authorComments1.get("2").get(0).size());

Map<String, List<String>> authorComments2 = blogs.stream()
 .collect(Collectors.groupingBy(Blog::getAuthorName,
  Collectors.flatMapping(blog -> blog.getComments().stream(),
  Collectors.toList())));

assertEquals(2, authorComments2.size());
assertEquals(2, authorComments2.get("1").size());
assertEquals(3, authorComments2.get("2").size());
}

Collectors.mapping映射所有分组（作者的评论）值收集的器容器中，如List。并且删除中间集合，直接存储集合至收集器的容器。

总结

本文介绍Java 9 提供Collectors新的方法。Collectors.filtering() 和 Collectors.flatMapping() ，一般和Collectors.groupingBy() 一起使用。

这些收集器也可以与collector.partitioningby()一起使用，但是仅根据条件创建两个分区，收集器的实际功能并没有得到利用;因此在本教程中没有提到。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持我们。

java8中parallelStream性能测试及结果分析

测试1 @BenchmarkMode(Mode.AverageTime) @OutputTimeUnit(TimeUnit.NANOSECONDS) @Warmup(iterations = 5, time = 3, timeUnit = TimeUnit.SECONDS) @Measurement(iterations = 20, time = 3, timeUnit = TimeUnit.SECONDS) @Fork(1) @State(Scope.Benchmark) public cla
Java8中利用stream对map集合进行过滤的方法

前言 Stream 是用函数式编程方式在集合类上进行复杂操作的工具,其集成了Java 8中的众多新特性之一的聚合操作,开发者可以更容易地使用Lambda表达式,并且更方便地实现对集合的查找.遍历.过滤以及常见计算等. 最近公司在大张旗鼓的进行代码审核,从中也发现自己写代码的不好习惯.一次无意的点到了公司封装的对map集合过滤的方法,发现了stream.于是研究了一下.并对原有的代码再次结合Optional进行重构下原有方法说明主要处理过滤条件Map对象,过滤掉了null和空字符串等操作这
Java8中Stream使用的一个注意事项

Stream简介我们先来看看Java里面是怎么定义Stream的: A sequence of elements supporting sequential and parallel aggregate operations. 我们来解读一下上面的那句话: Stream是元素的集合,这点让Stream看起来用些类似Iterator: 可以支持顺序和并行的对原Stream进行汇聚的操作: 大家可以把Stream当成一个高级版本的Iterator.原始版本的Iterator,用户只能一个一个的遍历
Java8新特性Stream流实例详解

什么是Stream流? Stream流是数据渠道,用于操作数据源(集合.数组等)所生成的元素序列. Stream的优点:声明性,可复合,可并行.这三个特性使得stream操作更简洁,更灵活,更高效. Stream的操作有两个特点:可以多个操作链接起来运行,内部迭代. Stream可分为并行流与串行流,Stream API 可以声明性地通过 parallel() 与sequential() 在并行流与顺序流之间进行切换.串行流就不必再细说了,并行流主要是为了为了适应目前多核机器的时代,提高系统CP
详解Java8 Collect收集Stream的方法

Collection, Collections, collect, Collector, Collectos Collection是Java集合的祖先接口. Collections是java.util包下的一个工具类,内涵各种处理集合的静态方法. java.util.stream.Stream#collect(java.util.stream.Collector<? super T,A,R>)是Stream的一个函数,负责收集流. java.util.stream.Collector 是一个收
Java中的BufferedInputStream与BufferedOutputStream使用示例

BufferedInputStream BufferedInputStream 是缓冲输入流.它继承于FilterInputStream. BufferedInputStream 的作用是为另一个输入流添加一些功能,例如,提供"缓冲功能"以及支持"mark()标记"和"reset()重置方法". BufferedInputStream 本质上是通过一个内部缓冲区数组实现的.例如,在新建某输入流对应的BufferedInputStream后,当我
Java中FilterInputStream和FilterOutputStream的用法详解

FilterInputStream FilterInputStream 的作用是用来"封装其它的输入流,并为它们提供额外的功能".它的常用的子类有BufferedInputStream和DataInputStream. BufferedInputStream的作用就是为"输入流提供缓冲功能,以及mark()和reset()功能". DataInputStream 是用来装饰其它输入流,它"允许应用程序以与机器无关方式从底层输入流中读取基本 Java 数据类
Java中getResourceAsStream用法分析

本文实例讲述了Java中getResourceAsStream用法.分享给大家供大家参考.具体如下: (一)Java中的getResourceAsStream有以下几种情况: 1. Class.getResourceAsStream(String path) : #path 不以'/'开头时默认是从此类所在的包下取资源: #以'/'开头则是从ClassPath根下获取,其原理是通过path构造一个绝对路径,最终还是由ClassLoader来获取资源. 2. Class.getClassLoade
Java9 Stream Collectors新增功能(小结)

Java 9 Stream Collectors新增功能 Java 8 引入Collectors,用于累加输入元素至可变的容器如,Map.List以及Set.本文看看Java 9 新增的两个Collectors:Collectors.filtering 和 Collectors.flatMapping,主要用于和 Collectors.groupingBy 一起提供智能的元素集合. Collectors.filtering方法 Collectors.filtering方法类似于Stream fi
SpringBoot实现文件上传下载功能小结

最近做的一个项目涉及到文件上传与下载.前端上传采用百度webUploader插件.有关该插件的使用方法还在研究中,日后整理再记录.本文主要介绍SpringBoot后台对文件上传与下载的处理. 单文件上传 // 单文件上传 @RequestMapping(value = "/upload") @ResponseBody public String upload(@RequestParam("file") MultipartFile file) { try { if (
SQL Server 2016 Alwayson新增功能图文详解

概述 SQLServer2016发布版本到现在已有一年多的时间了,目前最新的稳定版本是SP1版本.接下来就开看看2016在Alwyson上做了哪些改进,记得之前我在写2014Alwayson的时候提到过几个需要改进的问题在2016上已经做了改进. 一.自动故障转移副本数量在2016之前的版本自动故障转移副本最多只能配置2个副本,在2016上变成了3个. 说明:自动故障转移增加到三个副本影响并不是很大不是非常的重要,多增加一个故障转移副本也意味着你的作业也需要多维护一个副本.重要程度(一般).
谈谈 PHP7新增功能

php7发布已有半月,最近有时间了解一下php7的新特性,当然,这个版本最大的特点是性能的提升.在下并非高手,欢迎大家指出错误,同时期待共同交流. PHP语言一个非常重要的特点就是"弱类型",它让PHP的程序变得非常容易编写,新手接触PHP能够快速上手,不过,它也伴随着一些争议.支持变量类型的定义,可以说是革新性质的变化,PHP开始以可选的方式支持类型定义.除此之外,还引入了一个开关指令declare(strict_type=1);,当这个指令一旦开启,将会强制当前文件下的程序遵循严格
常用的JQuery函数及功能小结

1.文档加载完成执行函数 $(document).ready(function(){ alert("开始了"); }); 2.添加/删除CSS类 $("#some-id").addClass("NewClassName"); $("#some-id").removeClass("ClassNameToBeRemoved"); 3.选择符利用了CSS和Xpath(XML Path Language)选择符的
MSXML4.0 版中的新增功能

MSXML4.0 版中的新增功能 2001 年 9 月发行的 Microsoft XML Core Services (MSXML) 4.0 版中的新增功能 Microsoft Corporation 2001年10月下载 MSXML 4.0,网址为 MSDN Downloads(英文). 摘要: 本文重点介绍了与版本 3.0 相比,2001 年 9 月发行的 Microsoft XML Core Services (MSXML) 4.0 版中的新功能和重要变更. 目录简介新功能
使用layer弹窗和layui表单实现新增功能

1.需求:使用layer在弹窗内完成新增,成功后提示并刷新页面(父页面,list页面) 2.实现 a* 页面效果图 b*页面代码 --构建from表单 <div id="add-main" style="display: none;"> <form class="layui-form" id="add-form" action=""> <div class="layu
php7 新增功能实例总结

本文实例总结了php7 新增功能.分享给大家供大家参考,具体如下: 一.核心增加了group use语法声明.RFC: https://wiki.php.net/rfc/group_use_declarations 增加了null合并运算符??.RFC: https://wiki.php.net/rfc/isset_ternary 64位PHP7字符串长度可以超过2^31次方字节. 增加了Closure::call()方法. 双引号字符串和heredocs里面支持使用\u{xxxxx}来声明u
JDK15正式发布(新增功能预览)

JDK 15 在 2020 年 9 月 15 号正式发布了,这次发布的主要功能有: JEP 339:EdDSA 数字签名算法 JEP 360:密封类(预览) JEP 371:隐藏类 JEP 372:删除 Nashorn JavaScript 引擎 JEP 373:重新实现 Legacy DatagramSocket API JEP 374:重新实现 DatagramSocket API JEP 375:实例模式匹配(第二次预览) JEP 377:ZGC:一个可扩展的低延迟垃圾收集器 JEP 37
Java8 Collectors求和功能的自定义扩展操作

业务中需要将一组数据分类后收集总和,原本可以使用Collectors.summingInt(),但是我们的数据源是BigDecimal类型的,而Java8原生只提供了summingInt.summingLong.summingDouble三种基础类型的方法. 于是就自己动手丰衣足食吧.. 自定义工具类 public class MyCollectors { private MyCollectors() { } // public static <T> Collector<T, ?, Bi

Java9 Stream Collectors新增功能(小结)

相关推荐

随机推荐