flink_stat
2021-05-28 19:54:03 0 举报flink state
作者其他创作
大纲/内容
streamOperatorStateContext()
链表
Task内调用逻辑
initializeState()
StreamOperator
StateMapEntry_128可扩容
snapshotState()
StateMap_1
restore()
createStreamTaskStateInitializer()
StreamTaskStateInitializer
StateTable
数组
StateMapEntry_1
JM对state的控制
HeapRestoreOperation
StateMapEntry_2
StateMap_2
比较key&namespace
open()
operatorStateBackend()
StreamTask
FsStateBackend
StateMap_128
恢复
createStateBackend()
存储
StreamTask()
OperatorStateRestoreOperation
根据key & namespace 确定位置
1. JM中state启动运行流程2. TM中的state启动运行流程3. state的ck流程 (存储)4. state的restore流程 (恢复)5. 6.
createKeyedStateBackend()
StateMap_3
prepareSnapshotPreBarrier()
0 条评论
下一页
