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)
全栈程序员-站长的头像全栈程序员-站长


相关推荐

  • mysql中phpmyadmin安装教程_安装phpMyAdmin图文教程[通俗易懂]

    mysql中phpmyadmin安装教程_安装phpMyAdmin图文教程[通俗易懂]phpmyadmin的安装配置已经是老生常谈的话题了,网络上到处都可以找到相关的配置教程。但是,那些大多都是手动配置的,稍不留神,容易出错。因此站长今天在这里介绍的是,被很多phpmyadmin用户所忽略的phpmyadmin自带的安装程序,下面我们就开始一步一步来安装phpmyadmin。1、首先下载phpmyadmin3.4.11,这是目前最稳定无bug的版本,点击下载2、在你的web根目录新…

    2022年6月1日
    28
  • 圆通数据库泄露_数据库分析

    圆通数据库泄露_数据库分析今天的航空运单查询,其实质疑N快递单信息。版权声明:本文博主原创文章,博客,未经同意不得转载。转载于:https://www.cnblogs.com/mengfanrong/p/4808225.html…

    2022年9月19日
    2
  • mpeg4标准包含{xvid\divx,h264\avc}

    mpeg4标准包含{xvid\divx,h264\avc}“MPEG-4由一系列的子标准组成,被称为部……………………………第二部(ISO/IEC14496-2):视讯:定义了一个对各种视觉信息(包括视讯,静止纹理,计算机合成图形等等)的编解码器。对视讯部分来说,众多”Profiles”中很常用的一种是AdvancedSimpleProfile(ASP),例如XviD编码就属于MPEG-4

    2022年9月18日
    1
  • stacking的实现-mxtend库「建议收藏」

    TableofContents关于Stacked的实现库-mlxtend的学习StackingClassifier例子1简单实现stacking例子2sub-model的输出是probabilities例子3结合GridSearch列子4-针对不同整体选用不同模型StackingCVClassifier例子1简单stackingCV分类例子2sub-model的输出是prob…

    2022年4月8日
    46
  • pytest报错_eclipse提交代码到git

    pytest报错_eclipse提交代码到git前言我们每天写完自动化用例后都会提交到git仓库,随着用例的增多,为了保证仓库代码的干净,当有用例新增的时候,我们希望只运行新增的未提交git仓库的用例。pytest-picked插件可以

    2022年7月29日
    9
  • idea最新激活码-激活码分享

    (idea最新激活码)本文适用于JetBrains家族所有ide,包括IntelliJidea,phpstorm,webstorm,pycharm,datagrip等。IntelliJ2021最新激活注册码,破解教程可免费永久激活,亲测有效,下面是详细链接哦~https://javaforall.net/100143.html…

    2022年3月22日
    106

发表回复

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

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