Java8 Stream之groupingBy分组使用解读

Java8 Stream groupingBy分组 Java8 groupingBy分组 2023-05-17 20:05:33 582人浏览八月长安

Python 官方文档：入门教程 => 点击学习

摘要

目录Java8 Stream之groupingBy分组Collectors.groupingBy()分组之常见用法Collectors.groupingBy() 分组之统计每个分组的

Java8 Stream之groupingBy分组
Collectors.groupingBy()分组之常见用法
Collectors.groupingBy() 分组之统计每个分组的count
Collectors.groupingBy() 分组之统计分组平均值
Collectors.groupingBy() 分组之统计分组总值
Collectors.groupingBy() 分组之Join分组List
Collectors.groupingBy() 分组之转换分组结果List -> List
Collectors.groupingBy() 分组之转换分组结果List -> Set
Collectors.groupingBy() 分组之使用对象分组List
Collectors.groupingBy() 分组之使用两个成员分组List
自定义Distinct对结果去重
总结

Java8 Stream之groupingBy分组

本文主要讲解：Java 8 Stream之Collectors.groupingBy()分组示例

Collectors.groupingBy()分组之常见用法

功能代码：

    
    public void groupingByCity() {
        Map<String, List<Employee>> map = employees.stream().collect(Collectors.groupingBy(Employee::getCity));
 
        map.forEach((k, v) -> {
            System.out.println(k + " = " + v);
        });
    }

Collectors.groupingBy() 分组之统计每个分组的count

功能代码：

    
    public void groupingByCount() {
        Map<String, Long> map = employees.stream()
                .collect(Collectors.groupingBy(Employee::getCity, Collectors.counting()));
 
        map.forEach((k, v) -> {
            System.out.println(k + " = " + v);
        });
    }

Collectors.groupingBy() 分组之统计分组平均值

功能代码：

    
    public void groupingByAverage() {
        Map<String, Double> map = employees.stream()
                .collect(Collectors.groupingBy(Employee::getCity, Collectors.averagingInt(Employee::getAge)));
 
        map.forEach((k, v) -> {
            System.out.println(k + " = " + v);
        });
    }

Collectors.groupingBy() 分组之统计分组总值

功能代码：


    public void groupingBySum() {
        Map<String, Long> map = employees.stream()
                .collect(Collectors.groupingBy(Employee::getCity, Collectors.summingLong(Employee::getAmount)));
 
        map.forEach((k, v) -> {
            System.out.println(k + " = " + v);
        });
 
        // 对Map按照分组销售总值逆序排序
        Map<String, Long> sortedMap = new LinkedHashMap<>();
        map.entrySet().stream().sorted(Map.Entry.<String, Long> comparingByValue().reversed())
                .forEachOrdered(e -> sortedMap.put(e.geTKEy(), e.getValue()));
 
        sortedMap.forEach((k, v) -> {
            System.out.println(k + " = " + v);
        });
    }

Collectors.groupingBy() 分组之Join分组List

功能代码：


    public void groupingByString() {
        Map<String, String> map = employees.stream().collect(Collectors.groupingBy(Employee::getCity,
                Collectors.mapping(Employee::getName, Collectors.joining(", ", "Names: [", "]"))));
 
        map.forEach((k, v) -> {
            System.out.println(k + " = " + v);
        });
    }

Collectors.groupingBy() 分组之转换分组结果List -> List

功能代码：


    public void groupingByList() {
        Map<String, List<String>> map = employees.stream().collect(
                Collectors.groupingBy(Employee::getCity, Collectors.mapping(Employee::getName, Collectors.toList())));
 
        map.forEach((k, v) -> {
            System.out.println(k + " = " + v);
            v.stream().forEach(item -> {
                System.out.println("item = " + item);
            });
        });
    }

Collectors.groupingBy() 分组之转换分组结果List -> Set

功能代码：

    
    public void groupingBySet() {
        Map<String, Set<String>> map = employees.stream().collect(
                Collectors.groupingBy(Employee::getCity, Collectors.mapping(Employee::getName, Collectors.toSet())));
 
        map.forEach((k, v) -> {
            System.out.println(k + " = " + v);
            v.stream().forEach(item -> {
                System.out.println("item = " + item);
            });
        });
    }

Collectors.groupingBy() 分组之使用对象分组List

功能代码：

    
    public void groupingByObject() {
        Map<Manage, List<Employee>> map = employees.stream().collect(Collectors.groupingBy(item -> {
            return new Manage(item.getName());
        }));
 
        map.forEach((k, v) -> {
            System.out.println(k + " = " + v);
        });
    }

Collectors.groupingBy() 分组之使用两个成员分组List

功能代码：

    
    public void groupingBys() {
        Map<String, Map<String, List<Employee>>> map = employees.stream()
                .collect(Collectors.groupingBy(Employee::getCity, Collectors.groupingBy(Employee::getName)));
 
        map.forEach((k, v) -> {
            System.out.println(k + " = " + v);
            v.forEach((i, j) -> {
                System.out.println(i + " = " + j);
            });
        });
    }

自定义Distinct对结果去重

功能代码


    public void groupingByDistinct() {
        List<Employee> list = employees.stream().filter(distinctByKey(Employee :: getCity))
                .collect(Collectors.toList());;
 
        list.stream().forEach(item->{
            System.out.println("city = " + item.getCity());
        });
        
        
    }
 
    
    private static <T> Predicate<T> distinctByKey(Function<? super T, ?> keyExtractor) {
        Set<Object> seen = ConcurrentHashMap.newKeySet();
        return t -> seen.add(keyExtractor.apply(t));
    }

完整源代码：

package com.stream;
 
import java.util.ArrayList;
import java.util.Arrays;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.Random;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import java.util.function.Function;
import java.util.function.Predicate;
import java.util.stream.Collectors;
 

public class Java8GroupBy {
 
    List<Employee> employees = new ArrayList<Employee>();
 
    
    public void init() {
        List<String> citys = Arrays.asList("湖南", "湖北", "江西", "广西 ");
        for (int i = 0; i < 10; i++) {
            Random random = new Random();
            Integer index = random.nextInt(4);
            Employee employee = new Employee(citys.get(index), "姓名" + i, (random.nextInt(4) * 10 - random.nextInt(4)),
                    (random.nextInt(4) * 1000 - random.nextInt(4)));
            employees.add(employee);
        }
    }
 
    
    public void groupingByCity() {
        Map<String, List<Employee>> map = employees.stream().collect(Collectors.groupingBy(Employee::getCity));
 
        map.forEach((k, v) -> {
            System.out.println(k + " = " + v);
        });
    }
 
    
    public void groupingByCount() {
        Map<String, Long> map = employees.stream()
                .collect(Collectors.groupingBy(Employee::getCity, Collectors.counting()));
 
        map.forEach((k, v) -> {
            System.out.println(k + " = " + v);
        });
    }
 
    
    public void groupingByAverage() {
        Map<String, Double> map = employees.stream()
                .collect(Collectors.groupingBy(Employee::getCity, Collectors.averagingInt(Employee::getAge)));
 
        map.forEach((k, v) -> {
            System.out.println(k + " = " + v);
        });
    }
 
    
    public void groupingBySum() {
        Map<String, Long> map = employees.stream()
                .collect(Collectors.groupingBy(Employee::getCity, Collectors.summingLong(Employee::getAmount)));
 
        map.forEach((k, v) -> {
            System.out.println(k + " = " + v);
        });
 
        // 对Map按照分组销售总值逆序排序
        Map<String, Long> sortedMap = new LinkedHashMap<>();
        map.entrySet().stream().sorted(Map.Entry.<String, Long> comparingByValue().reversed())
                .forEachOrdered(e -> sortedMap.put(e.getKey(), e.getValue()));
 
        sortedMap.forEach((k, v) -> {
            System.out.println(k + " = " + v);
        });
    }
 
    
    public void groupingByString() {
        Map<String, String> map = employees.stream().collect(Collectors.groupingBy(Employee::getCity,
                Collectors.mapping(Employee::getName, Collectors.joining(", ", "Names: [", "]"))));
 
        map.forEach((k, v) -> {
            System.out.println(k + " = " + v);
        });
    }
 
    
    public void groupingByList() {
        Map<String, List<String>> map = employees.stream().collect(
                Collectors.groupingBy(Employee::getCity, Collectors.mapping(Employee::getName, Collectors.toList())));
 
        map.forEach((k, v) -> {
            System.out.println(k + " = " + v);
            v.stream().forEach(item -> {
                System.out.println("item = " + item);
            });
        });
    }
 
    
    public void groupingBySet() {
        Map<String, Set<String>> map = employees.stream().collect(
                Collectors.groupingBy(Employee::getCity, Collectors.mapping(Employee::getName, Collectors.toSet())));
 
        map.forEach((k, v) -> {
            System.out.println(k + " = " + v);
            v.stream().forEach(item -> {
                System.out.println("item = " + item);
            });
        });
    }
 
    
    public void groupingByObject() {
        Map<Manage, List<Employee>> map = employees.stream().collect(Collectors.groupingBy(item -> {
            return new Manage(item.getName());
        }));
 
        map.forEach((k, v) -> {
            System.out.println(k + " = " + v);
        });
    }
 
    
    public void groupingBys() {
        Map<String, Map<String, List<Employee>>> map = employees.stream()
                .collect(Collectors.groupingBy(Employee::getCity, Collectors.groupingBy(Employee::getName)));
 
        map.forEach((k, v) -> {
            System.out.println(k + " = " + v);
            v.forEach((i, j) -> {
                System.out.println(i + " = " + j);
            });
        });
    }
 
    
    public void groupingByDistinct() {
        List<Employee> list = employees.stream().filter(distinctByKey(Employee :: getCity))
                .collect(Collectors.toList());;
 
        list.stream().forEach(item->{
            System.out.println("city = " + item.getCity());
        });
        
        
    }
 
    
    private static <T> Predicate<T> distinctByKey(Function<? super T, ?> keyExtractor) {
        Set<Object> seen = ConcurrentHashMap.newKeySet();
        return t -> seen.add(keyExtractor.apply(t));
    }
 
    public static void main(String[] args) {
        // TODO Auto-generated method stub
        Java8GroupBy instance = new Java8GroupBy();
        instance.init();
        instance.groupingByCity();
        instance.groupingByCount();
        instance.groupingByAverage();
        instance.groupingBySum();
        instance.groupingByString();
        instance.groupingByList();
        instance.groupingBySet();
        instance.groupingByObject();
        instance.groupingBys();
        instance.groupingByDistinct();
 
    }
 
    class Employee {
        private String city;
        private String name;
        private Integer age;
        private Integer amount;
 
        public String getCity() {
            return city;
        }
 
        public void setCity(String city) {
            this.city = city;
        }
 
        public String getName() {
            return name;
        }
 
        public void setName(String name) {
            this.name = name;
        }
 
        public Integer getAge() {
            return age;
        }
 
        public void setAge(Integer age) {
            this.age = age;
        }
 
        public Integer getAmount() {
            return amount;
        }
 
        public void setAmount(Integer amount) {
            this.amount = amount;
        }
 
        public Employee(String city, String name, Integer age, Integer amount) {
            super();
            this.city = city;
            this.name = name;
            this.age = age;
            this.amount = amount;
        }
 
        public Employee() {
            super();
        }
    }
 
    class Manage {
        private String name;
 
        public String getName() {
            return name;
        }
 
        public void setName(String name) {
            this.name = name;
        }
 
        public Manage(String name) {
            super();
            this.name = name;
        }
 
        public Manage() {
            super();
        }
    }
 
}

总结

以上为个人经验，希望能给大家一个参考，也希望大家多多支持编程网。

您可能感兴趣的文档:

点击免费下载>>软考高级考试备考技巧/历年真题/备考精华资料

--结束END--

本文标题: Java8 Stream之groupingBy分组使用解读

本文链接: https://www.lsjlt.com/news/211449.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

本篇文章演示代码以及资料文档资料下载

下载Word文档到电脑，方便收藏和打印～

下载Word文档

去做题

猜你喜欢

Java8 Stream之groupingBy分组使用解读

目录Java8 Stream之groupingBy分组Collectors.groupingBy()分组之常见用法Collectors.groupingBy() 分组之统计每个分组的...

99+

2023-05-17

Java8 Stream groupingBy分组 Java8 groupingBy分组
Java8使用stream流给List＜Map＜String,Object＞＞分组(多字段key)

Java8使用stream流给List根据字段key分组一、项目场景：从已得到的List集合中，根据某一元素(这里指map的key)进行分组，筛选出需要的数据。如果是SQL的话则使用group ...

99+

2023-09-07

list java spring boot 后端
Java8特性之用Stream流代替For循环操作详解

目录准备一个实体类准备一个List集合传统的for循环使用Stream流先声明筛选条件，在遍历Stream操作嵌套循环（2层）准备一个实体类 public class Stud...

99+

2024-04-02
使用Java8进行分组(多个字段的组合分组)

目录java8分组传统写法（单个字段分组）java8分组传统写法（多个字段分组）分析：多个分组条件与单个分组条件两种写法多个字段的优雅写法再度优化在SQL中经常会用到分组，...

99+

2024-04-02
SpringSecurity之SecurityContextHolder使用解读

目录介绍ThreadLocalSecurityContextHolderStrategyInheritableThreadLocalSecurityContextHolderStra...

99+

2023-03-19

SpringSecurity SecurityContextHolder SecurityContextHolder使用
使用java8 新特性stream流对List＜Map＜String, Object＞＞集合进行遍历、过滤、查询、去重、排序、分组

对于一个List类型的数据，可以使用Java 8的新特性stream流来进行遍历、过滤、查询、去重、排序、分组等操作。遍历： List dataList = new ArrayList();//添加数据Map map1 = new Has...

99+

2023-09-08

list java
Kafka之kafka-topics.sh的使用解读

目录一、kafka的基本操作1.1、创建topic1.2、查看topic1.3、查看topic属性1.4、发送消息1.5、消费消息二、kafka-topics.sh 使用方式2.1、...

99+

2023-03-07

Kafka kafka-topics.sh kafka-topics.sh的使用使用kafka-topics.sh
Java8中新判空方法之Optional类的使用详解

目录认识OptionalOptional对象创建Optional.get()方法(返回对象的值)Optional.isPresent()方法(判读是否为空)Optional.ifPr...

99+

2022-12-30

Java8 Optional类判空 Java8 Optional类使用 Java8 Optional类
AndroidJetpack组件之ViewModel使用详解

目录ViewModel的诞生ViewModel的作用ViewModel的简单应用ViewModel的诞生解决以下几个问题：瞬态数据丢失异步调用的内存泄漏当我们取以异步操作区网络...

99+

2023-05-14

Android Jetpack ViewModel Android ViewModel
Java8用Stream流一行代码实现数据分组统计，排序，最大值、最小值、平均值、总数、合计

Java8对数据处理可谓十分流畅，既不改变数据，又能对数据进行很好的处理，今天给大家演示下，用Java8的Stream如何对数据进行分组统计，排序，求和等汇总统计方法找到汇总统计的方法。这些方法属于java 8的汇总统计类。getAve...

99+

2023-08-31

java 开发语言
详细解读VUE父子组件的使用

目录1.递归组件2.组件之间的循环使用二，深层次的问题**1.父传子****2.子传父***3.兄弟关系** 4.子组件复用5.父组件通过ref调用子组件的方法我们对父子组...

99+

2023-05-19

VUE 组件 VUE父子组件
在vue中完美使用ueditor组件(cdn)解读

目录vue使用ueditor组件(cdn)vue项目使用ueditor指南基本使用使用配置跳坑心得总结vue使用ueditor组件(cdn) 前言：无需main.js或页面全局或局部...

99+

2023-01-28

vue使用ueditor组件 vue ueditor组件 vue ueditor
怎么使用Java Stream API将List按自定义分组规则转换成Map

小编给大家分享一下怎么使用Java Stream API将List按自定义分组规则转换成Map，相信大部分人都还不怎么了解，因此分享这篇文章给大家参考一下，希望大家阅读完这篇文章后大有收获，下面让我们一起去了解一下吧！测试数据是List里的...

99+

2023-06-03
Flutter之 ListView组件使用示例详解

目录ListView的默认构造函数定义默认构造函数ListView.builder ListView.separated固定高度列表ListView 原理实例：无限加载列表...

99+

2022-11-13

Flutter ListView组件 Flutter ListView
Flutter绘图组件之CustomPaint使用详解

目录简介CustomPaint 介绍CustomPainter 示例总结简介在有些场景中，我们会需要绘制一些高度定制化的组件，比如 UI 设计师给我们出了个难题 —&m...

99+

2024-04-02
Flutter滚动组件之SingleChildScrollView使用详解

SingleChildScrollView SingleChildScrollView类似于Android中的ScrollView，它只能接收一个子组件。定义如下： const Si...

99+

2024-04-02
Python学习之元组的使用详解

目录元组的创建元组的删除元组部分元素的输出元组的嵌套元组元素的个数计算：len()元组中的元素最大最小值的求解：max(),min()元组中某元素出现的次数：count函数元组中某元...

99+

2024-04-02
Java8(291)之后禁用了TLS1.1使JDBC无法用SSL连接SqlServer2008怎么解决

这篇文章主要介绍“Java8(291)之后禁用了TLS1.1使JDBC无法用SSL连接SqlServer2008怎么解决”的相关知识，小编通过实际案例向大家展示操作过程，操作方法简单快捷，实用性强，希望这篇“Java8(291)之后禁用了T...

99+

2023-07-05
源码解析AndroidJetpack组件之ViewModel的使用

目录前言依赖版本基础使用定义Activity 中获取Fragment 中获取前置知识onSaveInstanceState、onRestoreInstanceStateonRetai...

99+

2023-05-17

Android Jetpack组件ViewModel的使用 Android Jetpack ViewModel使用 Android Jetpack ViewModel
flutter material widget组件之信息展示组件使用详解

flutter material widget组件之信息展示组件，供大家参考，具体内容如下 widget分为两类：widgets library中的标准widget和Material...

99+

2024-04-02