首页
学习
活动
专区
工具
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的时候被调用,传递的参数为

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

    聊聊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的时候被调用,传递的参数为

    75120

    扫码

    添加站长 进交流群

    领取专属 10元无门槛券

    手把手带您无忧上云

    扫码加入开发者社群

    相关资讯

    热门标签

    活动推荐

      运营活动

      活动名称
      广告关闭
      领券