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


相关推荐

  • 模块和包[通俗易懂]

    模块什么是模块:但其实import加载的模块分为四个通用类别:1使用python编写的代码(.py文件)2已被编译为共享库或DLL的C或C++扩展3包好一组模块的包4使用C编写并链

    2022年3月29日
    67
  • wsus可以打mysql中间件补丁_加入WSUS补丁服务器并下载补丁

    ——–加入WSUS补丁服务器并下载补丁_不安装——-@echooffregdeleteHKLM\SOFTWARE\Microsoft\Windows\CurrentVersion\WindowsUpdate/vAccountDomainSid/fregdeleteHKLM\SOFTWARE\Microsoft\Windows\CurrentVersion\Wind…

    2022年4月7日
    82
  • Db4o数据库:细说查询[通俗易懂]

    Db4o数据库:细说查询[通俗易懂]通过第一篇的介绍,相信大家也对Db4o有一定的了解,接下来就详细说一下有关查询的话题。Db4o原生支持3中查询模式:Query-By-Example:简称QBE,根据模板类进行匹配查询,这是最简单的一种模式NativeQuery:简称NQ,Db4o推荐的查询模式TheSODAAPI:这是Db4o底层查询API,官网文档解释,此API提供向后的兼容性,适用于动态

    2022年7月21日
    10
  • 皮尔逊相似度计算的例子(R语言)

    皮尔逊相似度计算的例子(R语言)

    2022年1月13日
    37
  • java handlersocket_HandlerSocket java客户端「建议收藏」

    java handlersocket_HandlerSocket java客户端「建议收藏」MySQL中有个handlersocket,直接跳过数据库处理中的sql分析过程,直接调用存储引擎的接口,可以大幅度提升数据库的性能。我的测试中,使用handlersocket与sql,可以提升约3-5倍,在我的环境中单条“增删改查”可以达到2.5TPS左右,没有作者说得可以达到10万TPS。有一个hs4j的java客户端,但是有些功能没有完善,还有一个不太正常的现象,就是连接时间长了,就会断开,…

    2022年8月24日
    3
  • 平衡二叉树的数据结构_红黑树数据结构

    平衡二叉树的数据结构_红黑树数据结构红黑树Java集合系列之TreeMap详细介绍(源码解析)和使用示例代码来自算法第四版红黑树并不追求“完全平衡”——它只要求部分地达到平衡要求,降低了对旋转的要求,从而提高了性能。红黑树实际上是由2-3-4树转换而来,红黑树能够以O(log2n)的时间复杂度进行搜索、插入、删除操作。此外,由于它的设计,任何不平衡都会在三次旋转之内解决。当然,还有一些更好的,但实现起来更复杂的数据

    2022年8月30日
    0

发表回复

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

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