Java 8 Streams API:对流进行分组和分区

这篇文章展示了如何使用Streams API中可用的Collectors将具有groupingBy的流元素和具有partitioningBy的流元素进行groupingBy

考虑一系列Employee对象,每个对象都有名称,城市和销售数量,如下表所示:

+----------+------------+-----------------+
| Name     | City       | Number of Sales |
+----------+------------+-----------------+
| Alice    | London     | 200             |
| Bob      | London     | 150             |
| Charles  | New York   | 160             |
| Dorothy  | Hong Kong  | 190             |
+----------+------------+-----------------+

分组

让我们开始使用命令式(Java-Lamba)按城市对员工进行分组:

Map<String, List<Employee>> result = new HashMap<>();
for (Employee e : employees) {String city = e.getCity();List<Employee> empsInCity = result.get(city);if (empsInCity == null) {empsInCity = new ArrayList<>();result.put(city, empsInCity);}empsInCity.add(e);
}

您可能熟悉这样的代码编写,并且您可以看到,完成如此简单的任务需要很多代码!

在Java 8中,您可以使用groupingBy收集器对单个语句执行相同的操作,如下所示:

Map<String, List<Employee>> employeesByCity =employees.stream().collect(groupingBy(Employee::getCity));

结果如下图:

{New York=[Charles], Hong Kong=[Dorothy], London=[Alice, Bob]}

通过将counting收集器传递给groupingBy收集器,还可以计算每个城市的雇员counting 。 第二收集器对分类到同一组的流中的所有元素执行进一步的还原操作。

Map<String, Long> numEmployeesByCity =employees.stream().collect(groupingBy(Employee::getCity, counting()));

结果如下图:

{New York=1, Hong Kong=1, London=2}

顺便说一句,这等效于以下SQL语句:

select city, count(*) from Employee group by city

另一个示例是计算每个城市的平均销售数量,可以使用averagingInt收集器结合groupingBy收集器来完成:

Map<String, Double> avgSalesByCity =employees.stream().collect(groupingBy(Employee::getCity,averagingInt(Employee::getNumSales)));

结果如下图:

{New York=160.0, Hong Kong=190.0, London=175.0}

分区

分区是一种特殊的分组,其中的结果映射最多包含两个不同的组-一个用于true ,一个用于false 。 例如,如果您想找出最好的员工是谁,则可以使用partitioningBy收集器将他们划分为销售额大于N的员工和不属于N的员工。

Map<Boolean, List<Employee>> partitioned =employees.stream().collect(partitioningBy(e -> e.getNumSales() > 150));

这将产生以下结果:

{false=[Bob], true=[Alice, Charles, Dorothy]}

您还可以通过将groupingBy收集器传递给partitioningBy收集器来组合分区和分组。 例如,您可以计算每个分区内每个城市的雇员人数:

Map<Boolean, Map<String, Long>> result =employees.stream().collect(partitioningBy(e -> e.getNumSales() > 150,groupingBy(Employee::getCity, counting())));

这将产生一个两层的Map:

{false={London=1}, true={New York=1, Hong Kong=1, London=1}}

翻译自: https://www.javacodegeeks.com/2015/11/java-8-streams-api-grouping-partitioning-stream.html

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

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

相关文章

vi/vim 编辑器详解

vi/vim &#xff1a; 强大的编辑器 进入vi的命令 vi filename :打开或新建文件&#xff0c;并将光标置于第一行首 vi n filename &#xff1a;打开文件&#xff0c;并将光标置于第n行首 vi filename &#xff1a;打开文件&#xff0c;并将光标置于最后一行首 vi /pattern …

linux 定义快捷命令,Linux系统自定义快捷命令的详细说明

Linux系统用户可以自定义喜欢的快捷键命令。下面由学习啦小编为大家整理了Linux系统自定义快捷键命令的详细说明&#xff0c;希望对大家有帮助!Linux系统自定义快捷命令的详细说明目前总结到的有两种方式&#xff0c;一种是临时快捷键&#xff0c;一种是永久快捷键。Linux系统自…

python求最小公倍数_python求最大公约数和最小公倍数的简单方法

python怎么求最大公约数和最小公倍数 一、求最大公约数 用辗转相除法求最大公约数的算法如下&#xff1a; 两个正整数a和b&#xff08;a>b&#xff09;&#xff0c;它们的最大公约数等于a除以b的余数c和b之间的最大公约数。比如10和25&#xff0c;25除以10商2余5&#xff0c…

linux如何获取raw中的文件路径,如何使用Linux获取Touchscreen Rawdata的坐标

我们有一个3米的微触摸显示屏.它通过usb连接到我的debian系统,并被识别为人机界面(hid).我正在尝试访问并推送实时信息…如果它被触及我想知道哪里(x,y)并通过netcat管道到另一台主机.不幸的是,我只能使用原始数据cat /dev/input/event2 | hexdump要么evtest你得到的hexcode似乎…

实验三+067+冯艳芳

一、实验目的 掌握黑盒测试用例设计方法 二、实验要求 &#xff08;1&#xff09;对被测程序进行黑盒测试用例设计 &#xff08;2&#xff09;运用等价类、边界值、决策表、状态图法等进行测试用例设计。 &#xff08;3&#xff09;对手机上任意一款音乐软件进行黑盒测试实践。…

python越来越慢_为什么Python中的串联速度越来越慢?

为什么在某些情况下,Python 3中的连接似乎比Python 2中的连接慢&#xff1f; 影响最大的串联方法似乎是字节对象的连续串联,从O(n)到O(n?)操作. 我的分析代码大部分在这里&#xff1a; #!/usr/bin/env python from operator import concat from sys import version, version_i…

jvm gc策略_IBM JVM调整– gencon GC策略

jvm gc策略本文将向您详细介绍从Java虚拟机&#xff08;例如HotSpot或JRockit&#xff09;迁移到IBM JVM时重要的Java堆空间调整注意事项。 此调整建议基于我为我的一个IT客户端执行的最新故障排除和调整任务。 IBM JVM概述 正如您可能从其他文章中看到的那样&#xff0c;IBM …

linux etc 服务启动脚本,linux 服务脚本启动问题

对于使用了 systemd 的系统&#xff0c;所有的 service 服务都会默认转为 systemd 服务之后再由 systemd 来执行&#xff0c;转换之后&#xff0c;你也可以直接使用 systemd 来执行了(它的用户工具就是你用的 systemctl)&#xff0c;除非是一些非 service 标准的命令&#xff0…

芬兰高性能图表控件-免费试用并提供技术支持

图表控件对于很多技术研发人员、工程设计师来说肯定不陌生&#xff0c;但市面上已有的图表控件产品大多功能单一、性能也不稳定&#xff0c;很难满足不同人群在不同场合的使用需求。为此&#xff0c;专注于开发高性能和最先进的数据可视化工具公司Arction则给出了完美的解决方案…

linux open函数_Linux驱动开发 / 字符设备驱动内幕 (1)

哈喽&#xff0c;我是老吴&#xff0c;继续记录我的学习心得。一、保持专注的几个技巧将最重要的事放在早上做。待在无干扰环境下&#xff0c;比如图书馆。意识到刚坐下开始投入工作前&#xff0c;有点负面小情绪是特别正常的现象。让“开心一刻”成为计划的一部分。拥有合情合…

xftp 无法连接linux 22端口,解决Xshell不从22端口连接服务器

PL&sol;SQL Developer主数据库连接和窗口连接切换Oracle开发者估计对PL/SQL Developer都非常熟悉了,里面有些小的功能点大概还有些初学者没发现.PL/SQL Developer支持多连接多窗口,下面详细说说. 主连接的概念 打开PL ...4 多表代替密码之Hill 密码 2实现该解密方法的KEY 不…

bzoj4484[JSOI2015]最小表示

题意 给出一张DAG,要求删除尽量多的边使得连通性不变.(即:若删边前u到v有路径,则删边后仍有路径).点数30000,边数100000. 分析 如果从u到v有(u,v)这条边,且从u到v只有这一条路径,那么这条边必须保留.否则这条边一定可以删除.因为如果有不止一条路径从u到v,必然存在点x(x!u,x!v)…

Enterprise Spring示例和集成测试

我的博客中的空白更长&#xff0c;因为我正在忙着写《 Pivotal认证的Spring企业集成专家考试–学习指南》 。 这本书是沉重的例子。 幸运的是&#xff0c;Apress同意开源所有这些示例。 因此&#xff0c; 在此GitHub存储库中有大量可用的Spring示例 。 总共146个带有集成测试的…

github删除文件_github 仓库中删除历史大文件

问题如果git中提交了大文件&#xff0c;而且保存到了版本库中&#xff0c;那在下载或者克隆git包的时候&#xff0c;速度会非常慢。再加上github在国内访问本来就很慢&#xff0c;可能会导致包无法下载(克隆)。为了提升下载(克隆)速度&#xff0c;可以永久的删除这些文件(包括该…

linux plc编程软件,基于Linux平台的可编程控制器软PLC设计

实例下面以一个简单的对3并口通道循环控制为例&#xff0c;说明软PLC 的工作流程。(1)梯形图编程。从软PLC 主界面进入后&#xff0c;启动梯形图编程&#xff0c;调用梯形图编程的主程序。梯形图编程共需要调用梯形图界面模块、关闭模块、IO 模块&#xff0c;这些均在配置文件中…

django的ModelForm

一、ModelForm 二、Ajax 原生 jQuery 伪Ajax操作 三、文件上传&#xff08;预览&#xff09; - Form提交&#xff08;会刷新页面&#xff09; - Ajax上传文件&#xff08;推荐&#xff09; 四、图片验证码&#xff08;跟session配合&#xff09; 五、CKEditor,UEEditor,TinyEdi…

insert into语句_入门MySQL——DML语句篇

前言&#xff1a;在上篇文章中&#xff0c;主要为大家介绍的是DDL语句的用法&#xff0c;可能细心的同学已经发现了。本篇文章将主要聚焦于DML语句&#xff0c;为大家讲解表数据相关操作。这里说明下DDL与DML语句的分类&#xff0c;可能有的同学还不太清楚。DDL(Data Definitio…

HBase shell 命令。

HBase shell 命令。 进入hbase shell console$HBASE_HOME/bin/hbase shell如果有kerberos认证&#xff0c;需要事先使用相应的keytab进行一下认证&#xff08;使用kinit命令&#xff09;&#xff0c;认证成功之后再使用hbase shell进入可以使用whoami命令可查看当前用户 hbase(…

python常用库有哪些餐厅_Python常用库整理

前两天有个同学问我关于Tkinter库的问题&#xff0c;但是我连Tkinter库是干啥的都不清楚&#xff0c;有点尴尬。Python库博大精深&#xff0c;涉及各个领域&#xff0c;多了解一些著名的库总比不知道的好。GUI图形界面TkinterwxPythonPyGTKPyQtPySideWeb框架Djangoweb2pyflaskb…

减少Java垃圾收集开销的5条提示

保持较低的GC开销的一些最有用的技巧是什么&#xff1f; 随着Java 9的一次再次延迟发布&#xff0c;G1&#xff08;“ Garbage First”&#xff09;垃圾收集器将设置为HotSpot JVM的默认收集器。 从串行垃圾收集器一直到CMS收集器&#xff0c;JVM在其整个生命周期中都见证了许…