实现方法

利用Collectors.toMap(Function keyMapper, Function valueMapper, BinaryOperator mergeFunction)
keyMapper：代表你最终想要获得的Map<Key, Value> 的Key
valueMapper：代表你最终想要获得的Map<Key, Value> 的Value
mergeFunction：表示碰到Key冲突是处理过程，{x, y}中x是已汇聚对象，y表示当前处理对象

对象类型数据处理

public static Map<String, Model> streamGroupSum(List<Model> datas){return datas.stream().collect(Collectors.toMap(k -> k.getCode(), v -> v, (x, y) -> x.addCount().addAll(y)));}

Model

@Data
class Model{private String code;private int count = 0;private Integer sum1;private Integer sum2;public Model(String code, Integer sum1, Integer sum2){this.code = code;this.sum1 = sum1;this.sum2 = sum2;}public Model addCount(){this.count++;return this;}public Model addAll(Model y){return add(Model::setSum1, Model::getSum1, y).add(Model::setSum2, Model::getSum2, y);}/*** 使用函数式编程，最终目的是为了求和，类似反射，具体使用方式请移步函数式编程*/public Model add(BiConsumer<Model, Integer> set, Function<Model, Integer> get, Model y){set.accept(this, get.apply(this) + get.apply(y));return this;}}

Map类型数据处理

public static void main (String[] args) {List<Map<String, Object>> datas = getDatas();streamMapSum(datas);}public static Map<Object, Map<String, Object>> streamMapSum (List<Map<String, Object>> datas) {return datas.stream().collect(Collectors.toMap(k -> k.get("name"), v -> {v.put("count", 1);return v;}, (x, y) -> {x.put("count", (int) x.get("count") + 1);x.put("aaa", (int) x.get("aaa") + (int) y.get("aaa"));x.put("bbb", (int) x.get("bbb") + (int) y.get("bbb"));x.put("ccc", (int) x.get("ccc") + (int) y.get("ccc"));return x;/*//使用ofMap重构return ofMap("name", x.get("name"), "count", (int) x.get("count") + 1, "aaa", add(x, y, "aaa"), "bbb", add(x, y, "bbb"), "ccc", add(x, y, "ccc"));*/}));}public static int add (Map<String, Object> x, Map<String, Object> y, String key) {return (int) x.get(key) + (int) y.get(key);}public static Map<String, Object> ofMap (Object... objs) {System.out.println("ofMap");Map<String, Object> map = new LinkedHashMap<>();for (int i = 0; i < objs.length; i = i + 2) {map.put(objs[i].toString(), objs[i + 1]);}return map;}public static List<Map<String, Object>> getDatas () {List<Map<String, Object>> list = new ArrayList<>();list.add(ofMap("name", "张三", "aaa", 3, "bbb", 5, "ccc", 6));list.add(ofMap("name", "张三", "aaa", 8, "bbb", 51, "ccc", 521));list.add(ofMap("name", "李四", "aaa", 9, "bbb", 53, "ccc", 23));return list;}

Java8 Stream 流多字段求和、汇聚相关推荐

java8 Stream流【华为3面】
华为三面@java8 stream流操作面试题前言:华为三面考了个很简单的基础编程,就是java8 Stream流操作,太久没写,也是没掌握好java基础直接搞得措手不及,stream两行代码的事情 ...
Java8——Stream流
Java8--Stream流 Stream是数据渠道,用于操作集合.数组等生成的元素序列. Stream操作的三个步骤: 创建Stream 中间操作终止操作一.获取stream的四种方式 1.通过 ...
java8 stream流将一个list转换成list
java8 stream流将一个对象集合转换成另一个对象集合案例一: // 利用stream进行类型转化 List<String> stringList = new Array ...
Java8 Stream 流一些使用整理（持续更新）
Java8 Stream 流一些使用整理双循环判断值原始写法 Stream 普通写法 Stream filter + anyMatch写法持续更新中双循环判断值原始写法 List<C ...
学习Java8 Stream流，让我们更加便捷的操纵集合
1. 概述本篇文章会简略的介绍一下 Lambda 表达式,然后开启我们的正题 Java8 Stream 流,希望观众老爷们多多支持,并在评论区批评指正! Java8 的 Stream 流使用的是函数 ...
[编程] Java8 Stream(流式计算) 常见的一些用法汇总
前提:以下基于 List<Student> 列表进行举例,大家实际使用进行举一反三即可.大同小异,Java8 的流式计算功能很强大,需要大家实际应用中逐渐挖掘更高级的用法. Student ...
Java8 Stream流操作在用户系统中的妙用
在做目前这个项目的时候,发现以前有一个筛选的需求,老程序员是这么做的,先请求Http服务器得到一长串json数据,大概用A4纸打了40多页那么多,然后将这些对象写入到sqlite数据库中,再用数据库查 ...
java8 stream流操作集合交集,差集,并集,过滤,分组,去重,排序,聚合等
测试对象 public class Person {private String name;private Integer age;private Integer weight;public Pers ...
Java8 Stream流中的 collect() 方法，远比你想象中的强大
Stream流 collect() 方法的使用介绍 //1. <R> R collect(Supplier<R> supplier,BiConsumer<R, ? sup ...

Java8 Stream 流多字段求和、汇聚

Stream 多字段求和、汇聚

实现方法

对象类型数据处理

Map类型数据处理

Java8 Stream 流多字段求和、汇聚相关推荐

最新文章

热门文章

Java8 Stream 流 多字段求和、汇聚

Stream 多字段求和、汇聚

实现方法

对象类型数据处理

Map类型数据处理

Java8 Stream 流 多字段求和、汇聚相关推荐

最新文章

热门文章

Java8 Stream 流多字段求和、汇聚

Java8 Stream 流多字段求和、汇聚相关推荐