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


相关推荐

  • idea的mybatis插件不联网可以使用吗_idea特效插件

    idea的mybatis插件不联网可以使用吗_idea特效插件IDEA的Mybatis插件idea不支持xml和映射器接口之间的跳转安装插件:FreeMybatisplugin使用指路:https://www.jianshu.com/p/4f1c2600802c

    2022年10月7日
    2
  • linux ll命令无效

    linux ll命令无效1.编辑~/.bashcvim~/.bashc若vi/vim命令无效,参考bash:vi:commandnotfound/bash:vim:commandnotfound2.重新执行刚修改的初始化文件source~/.bashc

    2022年6月23日
    31
  • 数据库中having用法[通俗易懂]

    数据库中having用法[通俗易懂]having经常与groupby和聚合函数(COUNT,SUM,AVG,MIN,orMAX)一起使用,用来过滤由GROUPBY语句返回的记录集。聚合函数通过作用于一组数据而只返回一个单个值,因此,在SELECT语句中出现的元素要么为一个聚合函数的输入值,要么为GROUPBY语句的参数,否则会出错。HAVING语句的存在弥补了WHERE关键字不能与聚合函数联合使用的不足。…

    2022年6月18日
    51
  • java线程与cpu线程_坑惨了什么意思

    java线程与cpu线程_坑惨了什么意思在java中,线程间的通信可以使用wait、notify、notifyAll来进行控制。从名字就可以看出来这3个方法都是跟多线程相关的,但是可能让你感到吃惊的是:这3个方法并不是Thread类或者是Runnable接口的方法,而是Object类的3个本地方法。下图是我总结的Java资料,想要资料的话请点795983544暗号CSDN。其实要理解这一点也并不难,调用一个Object的wait与notify/notifyAll的时候,必须保证调用代码对该Object是同步的,也就是说必须在作用等.

    2025年9月5日
    2
  • c语言读取bmp图像_opencv 图像处理

    c语言读取bmp图像_opencv 图像处理以前都是使C语言中File*、fopen、fread等操作文件,这几天学习了C++IO标准库,就应用来读取bmp图像。

    2022年9月19日
    2
  • Vue子组件向父组件传值(this.$emit()方法)「建议收藏」

    Vue子组件向父组件传值(this.$emit()方法)「建议收藏」子组件使用this.$emit()向父组件传值首先必须在父组件中引用子组件,然后实现传值 第一步在父组件中引入子组件 使用import引入组件importindexImportOrderfrom’./components/indexImportOrder’声明//定义组件components:{indexImportOrder,…

    2022年10月2日
    2

发表回复

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

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