知识卡片
KeyBy定义聚合归属
内容
keyBy 按键把数据分组，使同一 Key 的数据进入同一逻辑分组后再聚合。它不仅是函数调用，也是状态与负载分布的边界。发散：Key 选错，后续窗口和状态都会被拖偏。
参考来源
- 位置：《Flink原理与实践》第4章《DataStream API的介绍和使用》（源文件：_epub-src/OEBPS/Text/chapter07.xhtml）
- 结论依据：原文围绕“keyBy()会将一个DataStream转换为一个KeyedStream”给出定义、流程、对比或限制条件，本卡片据此提炼其可迁移的框架机制，并补充了使用边界或工程启发。
- 原始内容：如图4-6所示，keyBy()会将一个DataStream转换为一个KeyedStream，聚合操作会将KeyedStream转换为DataStream。