flink架构和关键组件

本质:Flink 算子在处理流数据时,需要保存的中间计算结果或历史信息,是算子的 “内存”。例如:窗口聚合中累计的订单数、用户会话的状态、CDC 同步中的数据版本号等。作用:支撑有状态的计算,让流处理...
4周前
120

Flink 快速入门

本文详细介绍了Apache Flink的系统架构和核心概念,适合深入学习和理解Flink的开发者。文章以Standalone会话模式为例,详细解析了Flink的作业提交和执行流程,包括客户端、JobM...
3周前
150