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)
上一篇 2022年10月5日 下午6:00
下一篇 2022年10月5日 下午6:00


相关推荐

  • openwrt安装aliddns使用阿里云ddns[通俗易懂]

    openwrt安装aliddns使用阿里云ddns[通俗易懂]openwrt安装aliddns使用阿里云ddns一些小伙伴安装了openwrt之后发现没法使用阿里云的ddns解析这里告诉你怎么添加aliddns插件需要会一些linux基础命令和ssh分四步安装依赖下载插件上传插件安装插件安装ddns-scripts、luci-app-ddns、openssl-util、wget依赖包使用luciweb界面里面的软件包管理,或者ssh使用opkg安装都一样有的openwrt自带的源地址可能下载很慢或根本无法下载,得换源下载alid

    2022年6月10日
    986
  • 2000款商务通用PPT模板免费下载[通俗易懂]

    2000款商务通用PPT模板免费下载[通俗易懂]0001-大气黑金年终工作总结PPT模板.zip:https://baippt.ctfile.com/fs/5288276-3454633710002-简约大气工作总结PPT模板.zip:https://baippt.ctfile.com/fs/5288276-3454633380003-商务风职业规划PPT模板.zip:https://baippt.ctfile.com/fs/5288…

    2022年7月24日
    17
  • Headless Chrome入门

    Headless Chrome入门HeadlessChro 指在 headless 模式下运行谷歌浏览器 本质就是不用谷歌运行谷歌 它将由 Chromium 和 Blink 渲染引擎提供的所有现代网页平台的特征都转化成了命令行 它有什么用 Headless 浏览器是一种很好的工具 用于自动化测试和不需要可视化用户界面的服务器 例如 你想在一个网页上运行一些测试 从网页创建一个 PDF 或者只是检查浏览器怎样递交 URL

    2026年3月19日
    2
  • 平板远程控制电脑_平板远程桌面

    平板远程控制电脑_平板远程桌面当下的局势,移动办公已经成为主流,远程控制工具也成为了我们日常办公不可或缺的软件。

    2025年8月22日
    4
  • Pycharm的安装和激活成功教程!

    Pycharm的安装和激活成功教程!先准备好安装软件 打开后 点击 Next 在上面箭头处选择安装路径 点击 Next 这两个选项一个是创建桌面快捷方式 一个是 py 文件 点击 Next 到达这个界面就可以直接选择安装了 红圈的意思是 运行 Pycharm 我们先不选 直接点击 Finsh 就可以 下面是激活成功教程部分 打开 Pycharm 的安装目录 在里面寻找 bi

    2026年3月27日
    1
  • 什么是RIA 技术?

    什么是RIA 技术?RIA是什么东西,这是真么技术。。。我写这篇博客中,就带着这么两个问题开始收集资料RIA(RichInterfaceApplications)富界面应用,俗称胖客户端.RIA的优势RIA具有的

    2022年7月4日
    25

发表回复

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

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