土法炼钢兴趣小组的算法知识备份

【流式数据处理】DataStream 与算子语义

2026-07-01 | database · distributed | #flink #datastream #shuffle #keyby #keygroup #processfunction #timerservice #operator-state #keyed-state #broadcast-state

拆解 Source/Transform/Sink 数据流图、rebalance/keyBy/broadcast 等 shuffle 策略、keyBy 到 KeyGroup 的映射，以及 ProcessFunction 与 TimerService 如何承载事件时间逻辑，并引入算子状态与键控状态的分工边界。