Java Stream如何使用reduce实现跨不同数据类型的归并操作

错误根因 #

你调用的是Stream接口的双参数reduce重载，方法签名如下：
T reduce(T identity, BinaryOperator<T> accumulator)
该重载仅支持同类型归并，约束规则为：

• 初始值identity类型必须与流元素类型T完全匹配
• 累加器accumulator为BinaryOperator<T>类型，需接收两个T类型入参、返回T类型结果
  对应到你的场景，流元素为One类型，编译器会强制校验传入的累加器必须匹配BinaryOperator<One>的类型要求。即使你在lambda中显式声明了Sum类型的累计值参数，编译逻辑依然会按照同类型规则校验，最终因为你编写的lambda返回Sum类型、不符合要求的One返回类型，触发Sum cannot be converted to One的编译报错。

正确实现逻辑 #

跨类型归并需使用Stream接口的三参数reduce重载，该方法从设计上支持流元素类型与归并结果类型解耦，方法签名为：
<U> U reduce(U identity, BiFunction<U, ? super T, U> accumulator, BinaryOperator<U> combiner)
三个参数的作用：

• identity：归并结果的初始值，类型可与流元素完全独立，直接传入Sum.INITIAL即可
• accumulator：核心累加逻辑，接收当前累计的U类型结果、当前遍历的T类型流元素，返回更新后的U类型结果，完全匹配你原有transformer.apply(sum, one)的计算逻辑
• combiner：并行流场景下的分片结果合并逻辑，接收两个同类型U值，返回合并后的U值；串行流场景下该逻辑不会被实际触发，但为了编译通过需提供合法实现

修正后代码 #

Sum finalResult = source.stream().reduce(
    Sum.INITIAL,
    (Sum sum, One one) -> transformer.apply(sum, one),
    (sumA, sumB) -> sumA.merge(sumB) // 替换为Sum类内置的两值合并方法即可
);

注意：combiner参数的逻辑必须和Sum类型的累计规则保持一致，若后续从串行流切换为并行流，该逻辑会直接参与结果计算，不能随意编写无效实现。

内容的提问来源于stack exchange，提问作者Maksim Maltsev