// //groupingBy分组
// Map<Integer, Long> map = houseList.stream().collect(Collectors.groupingBy(House::getBuildId, Collectors.counting()));
// //控制台输出map
// map.forEach((k,v)->{
// System.out.println("k="+k+",v="+v);
// });
//
// //方式二：使用1.8 stream流
// Map<Object, Integer> sum = houseList.stream().collect(Collectors.groupingBy(House::getBuildId, Collectors.summingInt(p -> ConvertUtil.obj2Int(p.get("count")))));
// sum.forEach((k, v) -> {
// newItems.add(ImmutableMap.of("daily", String.valueOf(k), "count", String.valueOf(v)));
// });// Map<String,Map<String, Map<String, List<House>>>> result = houseList.stream().collect(
//
// Collectors.groupingBy(House::getBuildId,
//
// Collectors.groupingBy(House::getClass,
//
// Collectors.groupingBy(House::getBuildId)))
//
// );
Map buildingCount = houseList.stream().collect(Collectors.groupingBy(House::getBuildId));int buildingCountSize = buildingCount.size();
public void testStreamGroupBy() {List<Map<String, Object>> items = Lists.newArrayList();Map<String, Object> map = Maps.newHashMap();map.put("daily", "2018-01-10");map.put("count", 20);items.add(map);map = Maps.newHashMap();map.put("daily", "2018-01-11");map.put("count", 80);items.add(map);map = Maps.newHashMap();map.put("daily", "2018-01-12");map.put("count", 21);items.add(map);map = Maps.newHashMap();map.put("daily", "2018-01-10");map.put("count", 28);items.add(map);final List<Map<String, Object>> newItems = Lists.newArrayList();//方式一： 使用遍历for (int i = 0; i < result.size(); i++) {Map<String, Object> oldMap = result.get(i);boolean isContain = false;for (int j = 0; j < newList.size(); j++) {Map<String, Object> newMap = newList.get(j);if (newMap.get("daily").equals(oldMap.get("daily"))) {for (String key : oldMap.keySet()) {newMap.put(key, oldMap.get(key));oldMap.put("count", (int) newMap.get("count") + (int) oldMap.get("count"));}isContain = true;break;}}if (!isContain) {newItems .add(oldMap);}}System.out.println("方式一：" + newItems );//方式二：使用1.8 stream流Map<Object, Integer> sum = items.stream().collect(Collectors.groupingBy(m -> m.get("daily"), Collectors.summingInt(p -> ConvertUtil.obj2Int(p.get("count")))));sum.forEach((k, v) -> {newItems.add(ImmutableMap.of("daily", String.valueOf(k), "count", String.valueOf(v)));});System.out.println("方式二："+newItems);}
java stream分组排序统计求和//java stream多条件分组//其中Student是学生，将学生依次以grade(年级) -> class(班级) -> teacher(任课老师) 分组Map<String,Map<String, Map<String, List<Student>>>> result = students.stream().collect(Collectors.groupingBy(Student::getGrade,Collectors.groupingBy(Student::getClass,Collectors.groupingBy(Student::getTeacher))));//多条件去重students.stream().collect(Collectors.collectingAndThen(Collectors.toCollection(() -> new TreeSet<>(Comparator.comparing(o -> o.getAge() + ";" + o.getName()))), ArrayList::new)).forEach(s -> println(s));//filter过滤students.stream().filter(s -> s.getAge() == 10).forEach(s -> println(s));//sorted排序students.stream().sorted(Comparator.comparing(s-> s.getAge())).forEach(s -> println(s));//1.自然序排序students.stream().sorted();//2.自然序逆序元素，使用Comparator 提供的reverseOrder() 方法students.stream().sorted(Comparator.reverseOrder());//3.按照年龄倒序排序students.stream().sorted(Comparator.comparing(Student::getAge).reversed());//4.不借助stream排序//分数正序排序chineseScores.sort(Comparator.comparing(Integer::intValue));//分数倒序排序chineseScores.sort(Comparator.comparing(Integer::intValue).reversed());//年龄正序排序students.sort(Comparator.comparing(Student::getAge));//年龄倒序排序students.sort(Comparator.comparing(Student::getAge).reversed());//limit方法限制最多返回多少元素students.stream().limit(2).forEach(s -> println(s));//不要前多n个元素，n大于满足条件的元素个数就返回空的流students.stream().skip(2).forEach(s -> println(s));//最大值 最小值Optional<User> min = students.stream().min(Comparator.comparing(Student::getAge));println(min);Optional<User> max = students.stream().max(Comparator.comparing(Student::getAge));println(max);//转单集合students.stream().map(Student::getName).forEach(name -> println(name));students.stream().mapToInt(Student::getAge).forEach(age -> println(age));students.stream().mapToDouble(Student::getScoreOfChinese).forEach(scoreOfChinese -> println(scoreOfChinese));students.stream().mapToLong(Student::getAge).forEach(getAge -> println(getAge));//转单集合求和students.stream().mapToDouble(Student::getScoreOfChinese).sum();//查找匹配指定数据是否存在//allMatch方法与anyMatch差不多，表示所有的元素都满足才返回true。noneMatch方法表示没有元素满足boolean anyMatch = students.stream().anyMatch(s -> s.getAge() == 100);boolean allMatch = students.stream().allMatch(s -> s.getName() == 'hello word');boolean noneMatch = students.stream().noneMatch(s -> s.getStudentId() == '10010');//简化操作 最大值，最小值，求和Optional<Integer> sum = list.stream().map(User::getAge).reduce(Integer::sum);Optional<Integer> max = list.stream().map(User::getAge).reduce(Integer::max);Optional<Integer> min = list.stream().map(User::getAge).reduce(Integer::min);println(sum);println(max);println(min);//统计IntSummaryStatistics statistics = students.stream().collect(Collectors.summarizingInt(User::getAge));double average = statistics.getAverage();long count = statistics.getCount();int max = statistics.getMax();int min = statistics.getMin();long sum = statistics.getSum();//转setSet<User> collect = students.stream().collect(Collectors.toSet());Iterator<User> iterator = collect.iterator();while(iterator.hasNext()) {System.out.println(iterator.next().getUserId());}//转mapMap<String, User> collect = students.stream().collect(Collectors.toMap(Student::getName, s -> s));for (String name : collect.keySet()) {//得到每个key多对用value的值Student s = collect.get(name);println(s);}
)
))
