Java8-07

1.什么是 reducing?

在 Java 8 中，Collectors.reducing 是Collectors类提供的一个强大的工具，用于进行归约操作。它用于将流中的元素按照某种规则进行累积，最终生成一个汇总结果。

Collectors.reducing(identity, op)

• identity：归约操作的初始值，也是流中没有元素时的默认值。
• op：一个二元操作符，用于将两个元素结合起来，执行归约操作。

2.使用示例?

下面是一个具体的例子，假设有一个包含整数的列表，我们希望对这些整数求和：

List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);

// 使用Collectors.reducing进行求和
Optional<Integer> sum = numbers.stream()
    .collect(Collectors.reducing((x, y) -> x + y));

// 打印结果
System.out.println("Sum: " + sum.orElse(0));

这个例子中，Collectors.reducing 接受一个 Lambda 表达式 (x, y) -> x + y 作为参数，表示对两个元素执行求和操作。sum 是一个Optional<Integer>，它包含了最终的求和结果。如果流为空，orElse(0) 将返回默认值 0。

3.使用优化

这个例子也可以通过方法引用来简化：

List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);

// 使用方法引用进行求和
int sum = numbers.stream()
    .collect(Collectors.reducing(0, Integer::sum));

// 打印结果
System.out.println("Sum: " + sum);

在这里，Integer::sum 是一个方法引用，表示执行整数求和操作。

4.复杂规约

Collectors.reducing 还可以用于更复杂的归约操作，例如查找最大值或最小值。下面是一个查找最大值的例子：

List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);

// 使用Collectors.reducing查找最大值
Optional<Integer> max = numbers.stream()
    .collect(Collectors.reducing(Integer::max));

// 打印结果
System.out.println("Max: " + max.orElse(0));

在这个例子中，Integer::max 是一个方法引用，表示执行整数的最大值操作。

5.实战应用?

有一个集合 storeReports,希望求不同分组策略下汇总值

1. 先根据不同的策略进行分组
2. 在 groupingBy 的内部进行 reducing 操作
3. new DTO()是初始值
4. 后面的函数是规约的具体逻辑

reducing实战:

Map<String, DTO> resultMap  = storeReports.stream()
                    .collect(Collectors.groupingBy(storeReportDTO -> isTotal ? storeReportDTO.groupKeyTotal() : storeReportDTO.groupKey(),
                            Collectors.reducing(new DTO(),
                                    (s1, s2) -> new DTO(
                                            s2.getName1(),
                                            s2.getKey(),
                                            s2.getYearName(),
                                            s2.getSeasonName(),
                                            Optional.ofNullable(s1.getSalQty()).orElse(0L) + Optional.ofNullable(s2.getSalQty()).orElse(0L),
                                            BigDecimal.ZERO,
                                            BigDecimal.ZERO,
                                            BigDecimal.ZERO,
                                            s2.getWeekOrMonth(),
                                            s2.getYear()
                                    )
                            )
                    ));

分组

public String groupKey() {
    return year + ":_:" + weekOrMonth + ":_:" + key + ":_:" + yearName + ":_:" + seasonName;
}
public String groupKeyTotal() {
    return year + ":_:" + weekOrMonth + ":_:" + key;
}