Flink中的State概念及其扩容算法 state是什么意思( 二 ) _资源

恢复状态的方式与源中操作者状态的存储结构有着必然的关系。让我们首先看看MetaQSource的实现是如何存储状态的。首先，MetaQSource实现ListCheckpointed，其中t是Tuple2 。我们看列表检查点接口的内部定义如下:
public interface ListCheckpointed { &创业网nbsp;List snapsh创业网otState(long var1, long var3) throws Exception;void restoreState(List var1) throws Exception;}我们发现snapshotState方法的返回值是一个list，t是Tuple2，也就是说snapshotState方法返回一个List 。该类型表示状态的存储是包含分区和偏移量信息的列表，InputSplit表示分区，Long表示当前分区读取的偏移量。InputSplit有一种方法如下:
public interface InputS创业网plit extends Serializable {int getSplitNumber();}也就是说，InputSplit可以理解为一个分区索引。有了这个数据结构，我们来看看上图所示的案例是如何工作的。当Source的并行度为1时，所有分区数据都在同一个线程中读取，所有分区的状态也保持在同一状态。状态存储信息的格式如下:

文章插图

Flink中的State概念及其扩容算法 state是什么意思( 二 )

推荐阅读

瀑布怎么拍好看

1立方米等于多少升1立方米是多少升

蓖麻子可以直接吃吗孕妇蓖麻子可以直接吃吗

海潮音乐节演出顺序 2023广州海潮宇宙音乐节门票可以换吗

植物营养基础知识植物营养

腔肠动物的主要特征腔肠动物

win10系统电脑打不开网页游戏怎么办？如何解决打不开网页游戏的方法

暴雨预警颜色等级哪个颜色最严重暴雨预警颜色等级有黑色吗

双子座暗恋一个人会有什么表现

山东烟台2023年专升本成绩什么时候可以查？

靠颜值才能脱单这些星座表示不需要

emo情绪有什么好方法可以缓解？

扬州公路超限运输许可办理地点在哪里

行车记录仪删除键在哪行车记录仪在车上删除怎么操作

威士忌酒吧威士忌酒

奶茶用芝士芝士奶茶正确喝法

香葱花卷怎么做

耳钉上的污垢怎么清洗

剑网3有多好玩，介绍一下，和天龙八部剑灵比怎么样

客官不可以歌词烟花易冷歌词