java8 groupingby_Java8stream中利用groupingBy进行多字段分组求和

java8 groupingby_Java8stream中利用groupingBy进行多字段分组求和对集合按照单个属性分组、分组计数、排序Listitems=Arrays.asList(“apple”,”apple”,”banana”,”apple”,”orange”,”banana”,”papaya”);//分组Map>result1=items.stream().collect(Collectors.groupingBy(Function.identity()));…

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺

对集合按照单个属性分组、分组计数、排序

List items =

Arrays.asList(“apple”, “apple”, “banana”,

“apple”, “orange”, “banana”,

“papaya”);

// 分组

Map> result1 = items.stream().collect(

Collectors.groupingBy(

Function.identity()

)

);

//{papaya=[papaya], orange=[orange], banana=[banana, banana],

apple=[apple, apple, apple]}

System.out.println(result1);

// 分组计数

Map result2 = items.stream().collect(

Collectors.groupingBy(

Function.identity(),

Collectors.counting()

)

);

// {papaya=1, orange=1, banana=2, apple=3}

System.out.println(result2);

Map finalMap = new LinkedHashMap<>();

//分组, 计数和排序

result2.entrySet().stream()

.sorted(Map.Entry.comparingByValue().reversed())

.forEachOrdered(e -> finalMap.put(e.getKey(),

e.getValue()));

// {apple=3, banana=2, papaya=1, orange=1}

System.out.println(finalMap);

集合按照多个属性分组

1.多个属性拼接出一个组合属性

public static void main(String[] args) {

User user1 = new

User(“zhangsan”, “beijing”, 10);

User user2 = new

User(“zhangsan”, “beijing”, 20);

User user3 = new

User(“lisi”, “shanghai”, 30);

List list = new

ArrayList();

list.add(user1);

list.add(user2);

list.add(user3);

Map> collect =

list.stream().collect(Collectors.groupingBy(e ->

fetchGroupKey(e)));

//{zhangsan#beijing=[User{age=10, name=’zhangsan’,

address=’beijing’}, User{age=20, name=’zhangsan’,

address=’beijing’}],

//

lisi#shanghai=[User{age=30, name=’lisi’,

address=’shanghai’}]}

System.out.println(collect);

}

private static String fetchGroupKey(User user){

return user.getName()

+”#”+ user.getAddress();

}

2.嵌套调用groupBy

User user1 = new User(“zhangsan”, “beijing”, 10);

User user2 = new User(“zhangsan”, “beijing”, 20);

User user3 = new User(“lisi”, “shanghai”, 30);

List list = new ArrayList();

list.add(user1);

list.add(user2);

list.add(user3);

Map>> collect

= list.stream().collect(

Collectors.groupingBy(

User::getAddress, Collectors.groupingBy(User::getName)

)

);

System.out.println(collect);

3. 使用Arrays.asList

我有一个与Web访问记录相关的域对象列表。这些域对象可以扩展到数千个。

我没有资源或需求将它们以原始格式存储在数据库中,因此我希望预先计算聚合并将聚合的数据放在数据库中。

我需要聚合在5分钟窗口中传输的总字节数,如下面的sql查询

select

round(request_timestamp, ‘5’) as window,

–round timestamp to the nearest 5 minute

cdn,

isp,

http_result_code,

transaction_time,

sum(bytes_transferred)

from web_records

group by

round(request_timestamp,

‘5’),

cdn,

isp,

http_result_code,

transaction_time

在java 8中,我当前的第一次尝试是这样的,我知道这个解决方案类似于Group by multiple field

names in java 8

Map>>>>>> aggregatedData =

webRecords

.stream()

.collect(Collectors.groupingBy(WebRecord::getFiveMinuteWindow,

Collectors.groupingBy(WebRecord::getCdn,

Collectors.groupingBy(WebRecord::getIsp,

Collectors.groupingBy(WebRecord::getResultCode,

Collectors.groupingBy(WebRecord::getTxnTime,

Collectors.reducing(0,

WebRecord::getReqBytes(),

Integer::sum)))))));

这是可行的,但它是丑陋的,所有这些嵌套的地图是一个噩梦!要将地图“展平”或“展开”成行,我必须这样做

for (Date window : aggregatedData.keySet()) {

for (String cdn :

aggregatedData.get(window).keySet()) {

for (String isp :

aggregatedData.get(window).get(cdn).keySet()) {

for

(String resultCode :

aggregatedData.get(window).get(cdn).get(isp).keySet()) {

for (String txnTime :

aggregatedData.get(window).get(cdn).get(isp).get(resultCode).keySet())

{

Integer

bytesTransferred =

aggregatedData.get(window).get(cdn).get(distId).get(isp).get(resultCode).get(txnTime);

AggregatedRow row = new AggregatedRow(window,

cdn, distId…

如你所见,这是相当混乱和难以维持。

有谁知道更好的方法吗?任何帮助都将不胜感激。

我想知道是否有更好的方法来展开嵌套的映射,或者是否有一个库允许您对集合进行分组。

最佳答案

您应该为地图创建自定义密钥。最简单的方法是使用Arrays.asList:

Function> keyExtractor = wr ->

Arrays.asList(wr.getFiveMinuteWindow(), wr.getCdn(),

wr.getIsp(),

wr.getResultCode(), wr.getTxnTime());

Map, Integer> aggregatedData =

webRecords.stream().collect(

Collectors.groupingBy(keyExtractor,

Collectors.summingInt(WebRecord::getReqBytes)));

在这种情况下,键是按固定顺序列出的5个元素。不是很面向对象,但很简单。或者,您可以定义自己的表示自定义键的类型,并创建适当的hashCode/equals实现。

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/171385.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • 9300反编译apk「建议收藏」

    9300反编译apk「建议收藏」1.首先,下载这货apktool_ics_jb_imobile.com.cn.rar(7.39MB,下载次数:589)奇怪版本的apktool,由1.4.2和1.4.4版混和而成2.请确保你已经安装了JDK,还有WinRAR之类的解压软件,如果没有自行解决吧3.将下载好的东西解压到某个文件夹里,如图(文件以压缩包实际所含文件为准,此图仅示意,下同):…

  • javascript操作元素的css样式

    javascript操作元素的css样式

  • opengl投影矩阵变换_opengl 坐标

    opengl投影矩阵变换_opengl 坐标前言先上一个运行效果图:OverviewAcomputermonitorisa2Dsurface.A3DscenerenderedbyOpenGLmustbeprojectedontothecomputerscreenasa2Dimage.GL_PROJECTIONmatrixisusedforthisprojectiontransformation.First,ittransformsallvertex…

  • 虚拟机连不上网问题详解「建议收藏」

    虚拟机连不上网问题详解「建议收藏」虚拟机连不上网问题详解第一虚拟机导航栏–编辑–虚拟机网络编辑器–VMnet0桥接模式(Inter(R)Wireless—AC9462)第二虚拟机导航栏–虚拟机–设置–网络适配器–NAT模式(VMnet0)–确定第三自己windows系统–服务–确保VMware开头的五个服务全部开启,并设置成自动开启最后打开虚拟机终端输入命令(重启网络服务)servicenetworkrestart我的是出现下面状态 [root@localhost~]#servicenetw

  • MySQL数据库语法_mysql建立学生表数据库

    MySQL数据库语法_mysql建立学生表数据库mysql数据库基本语法DDL操作创建数据库语法:createdatabase数据库名;查看所有数据库语法:showdatabases;切换(使用)数据库语法:use+数据库名;创建一个表语法:createtable表名(字段名称1字段类型,字段名称2字段类型,字段名称3字段类型,…………);查看数据库中所有表语法:Showtables;查看表的结构语法:desc表名;添加字段语法:alterta

  • Django安装教程_怎样安装ubuntu安装教程

    Django安装教程_怎样安装ubuntu安装教程第二步:安装django这一步由于网络问题可能会出现连接超时报错,只能重试:第三步:测试效果第四步:创建Django项目启动Web服务启动时会提示如下错如:解决办法:再运行就不会报错了。以上显示就是正常运行了,我们可以访问测试一下:返回状态码200表示成功!!!或者通过浏览器访问:参考:https://docs.djangoproject.com/en/4.0/intro/install/上一课1.1Docker安装Django下一课1.3完成一个简单的Demo

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号