知识卡片
Reduce保留同型聚合
内容
reduce 在 KeyedStream 上把同组元素滚动合并，输入和输出类型保持一致，适合累加、最大值等同型聚合。发散：当输出形状要改变时，reduce 就不是合适抽象。
参考来源
- 位置：《Flink原理与实践》第4章《DataStream API的介绍和使用》（源文件：_epub-src/OEBPS/Text/chapter07.xhtml）
- 结论依据：原文围绕“使用reduce()”给出定义、流程、对比或限制条件，本卡片据此提炼其可迁移的框架机制，并补充了使用边界或工程启发。
- 原始内容：前面几个Aggregation函数是较为常用的操作，对KeyedStream进行处理更为通用的方法是使用reduce()。