首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

聊聊flink的ListCheckpointed

CounterSource是一个有状态的RichParallelSourceFunction,它实现了ListCheckpointed接口,snapshotState方法返回了当前的offset,而restoreState...recovery, or try recovering * from a different checkpoint. */ void restoreState...(List state) throws Exception; } ListCheckpointed定义了两个接口,一个是snapshotState方法,一个是restoreState方法 snapshotState...方法,方法有个checkpointId参数,是唯一单调递增的数字,而timestamp则是master触发checkpoint的时间戳,该方法要返回当前的state(List结构) restoreState...方法;snapshotState方法在master触发checkpoint的时候被调用,用户需要返回当前的状态,而restoreState方法会在failure recovery的时候被调用,传递的参数为

83710
您找到你想要的搜索结果了吗?
是的
没有找到

聊聊flink的ListCheckpointed

CounterSource是一个有状态的RichParallelSourceFunction,它实现了ListCheckpointed接口,snapshotState方法返回了当前的offset,而restoreState...recovery, or try recovering * from a different checkpoint. */ void restoreState...(List state) throws Exception; } ListCheckpointed定义了两个接口,一个是snapshotState方法,一个是restoreState方法 snapshotState...方法,方法有个checkpointId参数,是唯一单调递增的数字,而timestamp则是master触发checkpoint的时间戳,该方法要返回当前的state(List结构) restoreState...方法;snapshotState方法在master触发checkpoint的时候被调用,用户需要返回当前的状态,而restoreState方法会在failure recovery的时候被调用,传递的参数为

71020

扫码

添加站长 进交流群

领取专属 10元无门槛券

手把手带您无忧上云

扫码加入开发者社群

相关资讯

热门标签

活动推荐

    运营活动

    活动名称
    广告关闭
    领券