关于checkpointFunction接口

classic Classic list List threaded Threaded
1 message Options
smq
Reply | Threaded
Open this post in threaded view
|

关于checkpointFunction接口

smq
大佬好,现在有个疑问,因为要用到自定义的state
保存某个值,这个状态是在keydprocessFunction实现类中用到的,我在sink的时候,实现了CheckpointFunction接口,实现了snapshotState方法,在这个方法中,我只写了一个flush到kudu的方法。这样的话我之前自己定义的state能保存到状态后端吗。
换句话说,就是snapshotState这个方法是在做checkpoint的同时调用了这个方法中的动作,还是说其他的状态不做了,只做我实现的snapshotState这个方法呢?