5.1.1 转换算子（Transformations）

文档摘要

5.1.1 转换算子（Transformations）在流式计算的世界里，数据不是静止的湖，而是奔涌的河——它没有起点，也无明确终点；它不等待被读取，只持续向前流淌。Flink 的 DataStream API，正是我们为这条河流建造的精密水利系统：闸门、分流渠、沉淀池、过滤网、计量站……每一处设施都对应一个转换算子（Transformation）。而 5.1.1 节所讨论的，不是泛泛而谈的“有哪些算子”，而是如何亲手铸造这些闸门与分流器——从字节级的序列化契约，到状态后端的内存布局；从并行度对 keyBy 分区逻辑的隐式约束，到 flatMap 中异常传播路径对 checkpoint 对齐的致命影响。