flinkState
2023-02-17 11:18:19 3 举报AI智能生成
简单分析flink state
作者其他创作
大纲/内容
Raw State
用户管理 自行实现序列化
Managed State
Operator State
可以用于所有算子
state
- BroadcastState（广播）
实现CheckpointedFunction等接口
ListState是将整个状态列表按照round-ribon的模式均匀分布到各个算子子任务上，每个 subtask 获取到其中一部分状态信息
UnionListState按照广播的模式，将整列表发送给每个算子子任务,每个 subtask 都获取到全量的状态信息
Keyed State（每个Key对应一个自己的状态）
适用于KeyedStream
重写RichFunction,通过getRuntimeContext()访问
状态随着Key自动在多个算子任务上转移
state
ValueState(存储一个值)
MapState(类似java.map)
AppendingState
ListState(类似java.list)
ReducingState(手动聚合)
AggregatingState(手动聚合)
收藏
0 条评论
下一页
为你推荐
查看更多
抱歉，暂无相关内容 
