(20) flink有状态的算子和应用程序

文章目录 算子状态(operator state) 键控状态(Keyed State) Flink内置的很多算子,数据源source,数据存储sink都是有状态的,流中的数据都是buffer records,会保存一定的元素或者元数据。例如: ProcessWindowFunction会缓存输入流的数据,ProcessFunction会保存设置的定时器信息等等。 在Flink中,状态始终与特定算子
相关文章
相关标签/搜索