归约操作java8_使用Java 8进行分组,转换和归约

归约操作java8

1.简介

在上一篇文章中 ,我写了关于如何使用流和分组对对象集合进行分组的文章。 这很有用,但不涵盖特定的用例。 例如,有时我们不仅需要对事物进行分组,还需要将结果转换为更合适的对象。

在这篇文章中,我们将学习如何将变换和归约应用于groupingBy结果。

  • 在这里,您可以查看以下示例的源代码。

2.分组并变换

让我们在上一篇文章中,我们不得不集合所使用的模型我的人谁拥有的宠物 。

现在,我们想知道哪些宠物属于居住在纽约的人。 我们要养宠物,所以我们不能只是分组,因为我们将要归还一群人。 我们需要做的是按城市分组人员,然后将流转换为宠物集合。

为此,我们在组的结果上使用以下映射:

public void groupAndTransform(List<Person> persons) {final Map<String, List<Pet>> petsGroupedByCity = persons.stream().collect(groupingBy(Person::getCity,mapping(Person::getPet, toList())));System.out.println("Pets living in New York: " + petsGroupedByCity.get("NYC"));
}

在分组阶段,我们按城市对人员进行分组,然后执行映射以获取每个人的宠物。

3.分组,转换和归约

前面的示例对于转换对象分组很有用,但是也许我们不想获取每个组的整个列表。 在此示例中,我们仍希望按所有者所在的城市对宠物进行分组,但是这次我们只想获取每个列表中最老的宠物。

来自Collectors的 collectionAndThen方法允许我们对分组结果进行最终转换:

public void groupTransformAndReduce(List<Person> persons) {final Map<String, Pet> olderPetOfEachCity = persons.stream().collect(groupingBy(Person::getCity,collectOlderPet()));System.out.println("The older pet living in New York is: " + olderPetOfEachCity.get("NYC"));
}private Collector<Person, ?, Pet> collectOlderPet() {return collectingAndThen(mapping(Person::getPet,Collectors.maxBy((pet1, pet2) -> Integer.compare(pet1.getAge(), pet2.getAge()))), Optional::get);}

在按城市对人员进行分组之后,在收集并随后将每个城市的列表中的每个人都转换为宠物,然后应用减法来获得列表中年龄最大的宠物。

4。结论

Collectors API不仅允许我们对事物的集合进行分组,而且还可以根据需要进行转换和简化以获得不同的对象。

翻译自: https://www.javacodegeeks.com/2016/03/grouping-transforming-reduction-java-8.html

归约操作java8

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/336391.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

C++ 11 深度学习(一)auto、头文件防卫、引用、常量

1.数组初始化 int a[]{ 1,2,3,4,5 }; 2.C11 auto auto可以在声明变量的时候根据变量的初始值的类型自动为此变量先择合适的类型&#xff0c;声明时要赋予初值。 auto自动推导发生在编译期间 auto A 10;//A会被自动推导为int类型 3.头文件防卫式声明 作用:防止头文件重…

flux storm_Apache Storm:如何使用Flux配置KafkaBolt

flux storm微型框架中的助焊剂可以帮助我们定义和部署Storm拓扑。 Flux有各种包装器&#xff0c;可帮助您定义所需的流并初始化Bolts和Spouts&#xff08;使用带有或不带有参数的构造函数&#xff0c;并通过反射自动调用自定义配置方法&#xff09;。 您只需要使用Flux就是将…

android 在什么情况下会主动gc_Python 什么情况下会生成 pyc 文件?

作者&#xff1a;折木奉太郎(经授权转载)来源&#xff1a;https://www.zhihu.com/question/30296617/answer/112564303作为 Python 爱好者&#xff0c;需要了解 .py 脚本的基本运行机制及特性&#xff1a;在很多工作上&#xff0c;Python 的运行流程基本上取决于用户&#xff0…

oracle 查看内存参数配置,Oracle内存参数配置及版本问题

Oracle的内存配置与Oracle性能息息相关。从总体上讲&#xff0c;可以分为两大块&#xff1a;共享部分(主要是SGA)和进程独享部分(主要是PGA)。在 32 位操作系统下 的Oracle版本&#xff0c;不时有项目反馈关于内存的错误(如ORA-04030、04031错误)都是十分令人头疼的问题。查阅资…

【IP协议头分析】

Version 版本号 IHL IP头长度 Type of Service Total Length 总长度 Identification 拆包的唯一标识 Flags 1位保留 &#xff0c; 2位 允许拆包 3位 不允许拆包 Fragment offset 在原包偏移量 Time to Live 时间或路由跳数 Protocol IP中是什么协议类型 Header Check…

乡村野生草药_官方野生蝇群流口水分数

乡村野生草药官方是什么&#xff1f; 标题太小&#xff0c;但有用的贡献。 Wildfly Swarm允许我们创建相当小的自包含应用程序&#xff0c;包括我们从Wildfly Application Server中需要的应用程序。 在这篇文章中&#xff0c;我们将研究与Wildfly Swarm合作使用的Drools分数 。…

obs多推流地址_(无人直播)教程利用OBS推流抖音直播电脑屏幕或PC游戏

目前的火爆程度相信大家都有目共睹&#xff0c;也為部分活躍用戶提供直播功能&#xff0c;開通直播的方法有&#xff1a;①粉絲達到10000粉絲&#xff0c;官方會自動邀請妳開通直播權限。②加入和官方合作的工會&#xff0c;無需粉絲&#xff0c;也可以開通直播權限。開通直播功…

oracle数据库sqlloader,sql loader ---ORACLE SQLLDR

sql loader的基本使用&#xff1a;1. sql loader里有几个概念&#xff1a;控制文件&#xff1a;和数据库的文件不是一回事&#xff0c;个人理解是用于数据加载控制的。数据文件&#xff1a;要加载入库的数据文件&#xff0c;支持文本&#xff0c;csv, 等格式。 数据文件的内容可…

倒数日电脑版_应用日报|iOS 或更名为 iPhoneOS,倒数日 Mac 版上线限时免费

今日推荐倒数日 Days Matter for Desktop免费&#xff0c;macOS 86 MB倒数日 Days Matter 是 iOS 端非常经典的应用&#xff0c;今天它的 Mac 版本上线&#xff0c;限时免费 7 天。它延续了 iOS 端的风格语言&#xff0c;同样能帮你记录生活中重要的日子&#xff1a;例如恋人…

【TPC协议头解析】

Source Port 源端口 Destination Port 目的端口 Sequence Number 数据报编号 (seq)&#xff08;按字节序&#xff09;保证有序 Acknowledgment Number (ACK) 报文应答, 保证可靠性 Data offset 跳到data数据部分 Reserved 保留部分 URG 紧急数据标识 ACK 确认消息…

hibernate查询缓存_在Hibernate中启用实体和查询缓存

hibernate查询缓存1.简介 在我执行过的与性能相关的任务中&#xff0c;这就是其中之一。 令人担心的是&#xff0c;如果对于特定实体每次都调用相同的查询&#xff0c;并且表数据在特定的时隙内不易更改&#xff0c;则我们可以使用Hibernate缓存查询结果。 这意味着&#xff0c…

iphone新旧手机数据传输已取消_如何取消iPhone手机App自动扣费?三种方法让你不再被“偷”...

一直以来苹果手机App这个自动续费真是让大家不胜其烦&#xff0c;钱虽然不多可总是平白无故这里十块&#xff0c;那里二十块的被扣也是不小的浪费&#xff0c;日常生活中为了追追剧、听听音乐、玩玩游戏难免会开通一些App会员而选择自动续费的话每月会费是有不错优惠的&#xf…

【TCP三次握手与四次挥手最强解析】

TCP连接拥塞控制四种方法总结&#xff08;详细简单&#xff0c;稳的一批&#xff09; TCP三次握手 作用&#xff1a;确认seqnumber&#xff1b;确定窗口大小以及最大报文大小 TCP四次挥手 WAIT_TIME状态到CLOSED需要2MSL时间&#xff08;最长单位MSL为2min,一般30s&#xff0…

oracle基础授权,Oracle基础学习3--Oracle创建用户并授权

Oracle服务器端的操作一般如下&#xff1a;1)安装Oracle服务器软件2) 创建数据库(安装时自动创建)3) 配置监听(安装时自动配置)4) 启动Oracle实例5) 创建用户表空间6) 创建新用户并授权下面就开始讲创建用户表空间、创建新用户并授权两项&#x…

mybatis缓存二级缓存_MyBatis缓存与Apache Ignite的陷阱

mybatis缓存二级缓存一周前&#xff0c;MyBatis和Apache ignite 宣布支持apache ignite作为MyBatis缓存&#xff08;L2缓存&#xff09;。 从技术上讲&#xff0c;MyBatis支持两个级别的缓存&#xff1a; 本地缓存&#xff0c;默认情况下始终启用 L2缓存&#xff0c;可选 随…

【H.264/AVC视频编解码技术】第一章【H264视频编码详细解析】

H264压缩比 YUV格式为 YUV420 分辨率 640 x 480 帧率 15 ,比特率为 640 x 480 x 1.5 x 15 x 8 =55M ,建议码流 500kpbs 。 压缩率 1 / 100 声网权威推荐码流 GOP 所谓GOP,意思是画面组,MPEG格中的帧序列,分为I、P、B三种,如排成IBBPBBPBBPBBPBBP...样式,这种…

企业是否应该实现对客户需求的快速响应_CRM系统给企业带来的创新有哪些?如何让销售爱用CRM系统?...

对于现代企业来说&#xff0c;CRM已然成为了一个成熟的项目&#xff0c;是能够给客户带来不菲的价值的。如果应用好&#xff0c;是能够取得提高客户满意度与企业经济效益的双赢成绩的。一、目前&#xff0c;CRM能够给企业带来的业务创新有哪些&#xff1f;1.统一数据CRM系统能将…

脚本实现oracle服务启停,通用服务启停shell脚本

####################################通用启停脚本#david###################################APP_NAMEmyApppsid0checkpid() {redisPidps -ef | grep $APP_NAME | grep -v grep | awk {print $2}if [[ -n "$myAppPid" ]]; thenpsid$myAppPidelsepsid0fi}status() {…