Tag: stream-processing
All the articles with the tag "stream-processing".
-
Flink 深挖 · 时间语义、窗口与 Watermark
Flink 时间语义与乱序:processing/ingestion/event time 取舍、Watermark 与多输入取 min、Tumbling/Sliding/Session 窗口、allowedLateness 与侧输出兜底、增量/全量聚合。
-
Flink 深挖(开篇)· 流处理模型与运行时架构
Flink 深挖开篇:为何广告实时链路选 Flink 而非微批、DataStream 流处理心智、JobManager/TaskManager/Slot 运行时、StreamGraph→JobGraph→ExecutionGraph 转换与算子链、部署模式。