BroadcastState中似乎并没有用到与CheckpointedFunction接口相关的类，在两个数据流中也没有实现这个接口

BroadcastState中似乎并没有用到与CheckpointedFunction接口相关的类，在两个数据流中也没有实现这个接口，只是在算子操作的过程中使用到了MapStateDescriptor。那是否意味着当前这个案例并不会被checkpoint执行snapshot的时候将数据持久化到外部存储系统中呢？

蒋昌魁 2023-11-05

源自：Flink1.15新特性及状态的使用 3-15 OperatorState案例之BroadcastState的使用（下）

9

收起

1回答

徐老师回答被采纳获得+3积分 2023-11-05 16:09:58

在这个案例里面，broadcaststate是为了广播mapstate。在checkpoint期间，只会存储mapstate的数据。broadcaststate只是负责广播mapstate中的数据而已。

蒋昌魁提问者 #1

老师，我记得课程里有提到，checkpoint期间，是通过snapshotState这个方法来将数据持久化到外部存储系统的。但是我发现这里，以及包括之前的RichFlatMapFunction这些类和它的父类中也都没有snapshotState相关的方法和默认实现。那么这些类中定义了state之后，是flink程序中通过反射封装好了逻辑，自动的扫描程序中相关的state，然后在checkpoint期间自动的进行持久化操作吗？

2023-11-05 20:20:11
徐老师回复提问者蒋昌魁 #2

RichFLatmapFunction并不是有状态的算子，也就是说这个算子里面默认没有用到state，所以没有持久化状态的相关方法。大部分的source,sink，以及中间的转换算子都不是有状态的，想要在里面使用状态，需要自己实现状态接口，并且覆盖相关方法。例如前面创建的mybuffersink。

2023-11-06 08:40:45
徐老师 #3

针对keyedstate类型的state，不需要自己实现snapshot这些接口，而broadcaststate又是一个特殊的state，只是为了广播数据，底层用的还是mapstate。

2023-11-06 08:56:19

点开查看后面3条评论

相似问题

关于接口的几个问题

关于抽象类实现接口的问题

接口和父类

老师，为什么我的订单中的数据是从其他接口获取的？

6.9，匿名内部类怎么实现接口？

登录后可查看更多问答，登录/注册

大数据工程师

参与学习 1168 人
提交作业 6095 份
解答问题 1171 个

不用Java初级内容充数！不用与大数据岗位无关内容占课时！我们做的就是“精华版”大数据课程

本课精华内容

问答作业

老师，每个比较大的文件都会分割成块保存在DataNode中，那就说一个datanode坏了导致整个文件不可用，这样不就减低了可靠性吗？

56 2

对多个executor并行处理，对数据进行去重，这样会不会有重复数据

32 1

数据倾斜问题

78 5

并行度调优疑问

29 9

yum install -y ntpdate执行报错

19 22

查看更多本课问答

请稍等 ...

意见反馈帮助中心 APP下载