stream的分组_java快速对list分组

stream的分组_java快速对list分组Stream流-分组操作文章目录Stream流-分组操作方法1,`groupingBy(Function)`方法2,`groupingBy(Function,Collector)`方法3:`groupingBy(Function,Supplier,Collector)`Collectors.groupingBy()3个方法的使用示例/**员工*@authorYang*@create2020-07-0919:57*/publicclassEmployee{

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

Jetbrains全系列IDE稳定放心使用

Stream流-分组操作

Collectors.groupingBy()3个方法的使用示例

/**员工 * @author Yang * @create 2020-07-09 19:57 */
public class Employee { 
   
    
    private String name;   // 姓
    private String city;   // 城市
    private Integer sales;  // 销售额

    public Employee(String name, String city, Integer sales) { 
   
        this.name = name;
        this.city = city;
        this.sales = sales;
    }

    public Employee(String city, Integer sales) { 
   
        this.city = city;
        this.sales = sales;
    }

    public Employee() { 
   
    }

    // getter(),setter() ....略
    
    @Override
    public String toString() { 
   
        return "Employee{" +
                "name='" + name + '\'' +
                ", city='" + city + '\'' +
                ", sales=" + sales +
                '}';
    }
}
    //-------------------生成测试数据---------------------
    private List<Employee> getEmps(){ 
   
        List<Employee> list = new ArrayList<>();
        Random rd = new Random();
        String[] citys = { 
   "北京","上海","广州","杭州","深圳"};
        String[] firstName = { 
   "张","李","杨","宁","刘","王","高","葛"};
        Integer[] sales = { 
   100,50,30,20};

        for (int i = 0; i < 10; i++) { 
   
            String city = citys[rd.nextInt(5)];
            Integer sale = sales[rd.nextInt(4)];
            String fname = firstName[rd.nextInt(firstName.length)];

            list.add(new Employee(fname,city,sale));
        }

        return list;
    }

方法1– groupingBy(Function)

一个参数:一个分组器,使用提供的字段对集合元素进行分组,返回一个Map<字段,相同字段值的元素集>

    /** * groupBy方法1,groupingBy(Function) * * 要求:先按city分组,每个分组里面是一个员工集合 */
    @Test
    public void test5(){ 
   
        List<Employee> emps = getEmps();

        Map<String, List<Employee>> map = emps.stream().collect(Collectors.groupingBy(Employee::getCity));

        map.forEach((key,val)->{ 
   
            System.out.println("城市:"+key+" ---员工集: "+val);
        });
    }
    /** * 城市:广州 ---员工集: [Employee{name='1', city='广州', sales=100}, Employee{name='5', city='广州', sales=20}, Employee{name='6', city='广州', sales=30}, Employee{name='8', city='广州', sales=30}] * 城市:上海 ---员工集: [Employee{name='0', city='上海', sales=30}] * 城市:杭州 ---员工集: [Employee{name='2', city='杭州', sales=50}, Employee{name='7', city='杭州', sales=30}] * 城市:北京 ---员工集: [Employee{name='3', city='北京', sales=30}, Employee{name='4', city='北京', sales=50}, Employee{name='9', city='北京', sales=30}] */

方法2– groupingBy(Function,Collector)

2个参数:一个是分组器,按提供的字段进行分组。一个收集器,下面举例了3种用途

    /** * groupBy方法2,groupingBy(Function,Collector) * * 要求:先按city分组 ,再对组里面的成员,统计总销售额 */
    @Test
    public void test3(){ 
   
        List<Employee> emps = getEmps();
        for (Employee emp : emps) { 
   
            System.out.println(emp);
        }

        Map<String, Integer> map = emps.stream().
                collect(Collectors.groupingBy(Employee::getCity, Collectors.summingInt(Employee::getSales)));
        // 先按city分组 再对组里面的成员,统计总销售额
        map.forEach((key,val)->{ 
   
            System.out.println("城市:"+key+" 销售总额:"+val);
        });
    }
    /** * Employee{name='0', city='上海', sales=50} * Employee{name='1', city='广州', sales=20} * Employee{name='2', city='广州', sales=30} * Employee{name='3', city='广州', sales=20} * Employee{name='4', city='杭州', sales=30} * Employee{name='5', city='杭州', sales=50} * Employee{name='6', city='北京', sales=50} * Employee{name='7', city='广州', sales=20} * Employee{name='8', city='杭州', sales=100} * Employee{name='9', city='广州', sales=30} * 城市:广州 销售总额:120 * 城市:上海 销售总额:50 * 城市:杭州 销售总额:180 * 城市:北京 销售总额:50 */
    /** * groupBy方法2,groupingBy(Function,Collector) * * 即:获取每个城市的姓氏集 * 先按城市分组,再对每个组里面的员工姓名放入Set,得到每个城市的姓氏集 */
    @Test
    public void test4(){ 
   
        List<Employee> emps = getEmps();
        Map<String, Set<String>> map = emps.stream().collect(Collectors.groupingBy(Employee::getCity, Collectors.mapping(Employee::getName, Collectors.toSet())));
        map.forEach((key,val)->{ 
   
            System.out.println(""+key+" ---人员姓名: "+val);
        });
    }
    /** * 上海 ---人员姓名: [葛] * 广州 ---人员姓名: [张, 刘, 王] * 杭州 ---人员姓名: [杨, 刘, 葛] */
    /** * groupBy方法2,groupingBy(Function,Collector) * 要求:每个城市中销售额最大的员工 * 先按城市分组,在求分组里面销售额最大的员工 */
    @Test
    public void test6(){ 
   
        List<Employee> emps = getEmps();
        
        Map<String, Employee> map = emps.stream().collect(Collectors.groupingBy(Employee::getCity,
                Collectors.collectingAndThen(Collectors.maxBy(Comparator.comparingInt(Employee::getSales)), Optional::get)));

        map.forEach((key,val)->{ 
   
            System.out.println("城市:"+key+" 销售额最大员工:"+val);
        });
    }
   /** * Employee{name='杨', city='北京', sales=100} * Employee{name='杨', city='杭州', sales=20} * Employee{name='葛', city='深圳', sales=30} * Employee{name='张', city='上海', sales=50} * Employee{name='杨', city='广州', sales=50} * Employee{name='张', city='上海', sales=20} * Employee{name='张', city='上海', sales=50} * Employee{name='刘', city='北京', sales=50} * Employee{name='高', city='深圳', sales=100} * Employee{name='葛', city='深圳', sales=30} * 城市:广州 销售额最大员工:Employee{name='杨', city='广州', sales=50} * 城市:上海 销售额最大员工:Employee{name='张', city='上海', sales=50} * 城市:杭州 销售额最大员工:Employee{name='杨', city='杭州', sales=20} * 城市:深圳 销售额最大员工:Employee{name='高', city='深圳', sales=100} * 城市:北京 销售额最大员工:Employee{name='杨', city='北京', sales=100} */

方法3– groupingBy(Function,Supplier,Collector)

参数:一个分组器,一个最终类型的生产者,一个收集器

下面的示例:先按城市分组,然后收集每个城市的姓氏集,然后放入一个TreeMap,得到最终结果。(按城市名称排了序

   /** * 3个参数的方法:groupingBy(Function,Supplier,Collector) * 要求:要计算每个城市中人的姓氏集,并对城市名称进行排序 * 先按城市分组,在对每个城市 */
    @Test
    public void test7(){ 
   
        List<Employee> emps = getEmps();
        TreeMap<String, Set<String>> map = emps.stream().collect(Collectors.groupingBy(Employee::getCity, TreeMap::new, Collectors.mapping(Employee::getName, Collectors.toSet())));
        map.forEach((key,val)->{ 
   
            System.out.println("城市:"+key+" 姓氏集:"+val);
        });
    }
    /** * 城市:上海 姓氏集:[刘] * 城市:北京 姓氏集:[宁, 李] * 城市:广州 姓氏集:[张, 高, 葛] * 城市:杭州 姓氏集:[张, 高, 葛] */
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请联系我们举报,一经查实,本站将立刻删除。

发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/185601.html原文链接:https://javaforall.net

(0)
全栈程序员-站长的头像全栈程序员-站长


相关推荐

  • kotlin和java互转

    kotlin和java互转其实就是互转 以下基于 IDEA 或 AndroidStudi 转 Kotlin 打开要转的文件方法 1Ctrl Shift Alt K 方法 2Code ConvertJavaF 转 JavaTools gt Kotlin gt ShowKotlinBy

    2025年6月18日
    0
  • 移动APP漏洞自动化检测平台建设

    移动APP漏洞自动化检测平台建设前言:本文是《移动APP客户端安全笔记》系列原创文章中的第一篇,主要讲的是企业移动APP自动化漏洞检测平台建设,移动APP漏洞检测发展史与前沿技术,APP漏洞检测工具与平台,以及笔者的一些思考。希望能对移动App自动化漏洞检测感兴趣的同学有所帮助,限于笔者技术水平与文章篇幅,有些内容暂没有逐一详细分析,后续我争取多学习多分享,在此也欢迎大家指点和交流。一、国内AndroidApp漏洞检测

    2022年5月27日
    28
  • Idea激活码最新教程2023.1.6版本,永久有效激活码,亲测可用,记得收藏

    Idea激活码最新教程2023.1.6版本,永久有效激活码,亲测可用,记得收藏Idea 激活码教程永久有效 2023 1 6 激活码教程 Windows 版永久激活 持续更新 Idea 激活码 2023 1 6 成功激活

    2025年5月27日
    0
  • VC++键盘钩子demo

    VC++键盘钩子demoHHOOKkeyHook=NULL;//先声明函数,实现在下面LRESULTCALLBACKkeyProc(intnCode,WPARAMwParam,LPARAMlParam);//初始化钩子,关闭键盘事件(除了ALT+CTRL+DELETE)voidinitHook(){ keyHook=SetWindowsHookEx(WH_KEYBOARD_LL,keyProc,GetModuleHandle(NULL),0);}//销毁钩子voidun.

    2022年6月14日
    26
  • java中list对象和json字符串互转

    java中list对象和json字符串互转java中list对象和json字符串互转importcom.alibaba.fastjson.JSON;importjava.util.List;publicclassJsonListUtil{/***List<T>转json字符串*/publicstatic<T>StringlistToJson(List<T>ts){returnJSON.toJSONString(ts);

    2022年10月17日
    0
  • Alex 的 Hadoop 菜鸟教程: 第1课 hadoop体系介绍

    Alex 的 Hadoop 菜鸟教程: 第1课 hadoop体系介绍介绍hadoop的体系,对hadoop庞大的生态圈进行了介绍,并标出了学习的优先级。简单明了的介绍,看了不晕

    2022年4月26日
    54

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

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