类 CheckpointAlgorithmAdapter

    • 方法概要

      所有方法 实例方法 具体方法 
      修饰符和类型方法说明
      booleanisComplete​(RepeatContext context)
      Allow policy to signal completion according to internal state, without having to wait for the callback to complete.
      booleanisComplete​(RepeatContext context, RepeatStatus result)
      Determine whether a batch is complete given the latest result from the callback.
      RepeatContextstart​(RepeatContext parent)
      Create a new context for the execution of a batch.
      voidupdate​(RepeatContext context)
      If CheckpointAlgorithm.isReadyToCheckpoint() is true we will call CheckpointAlgorithm.endCheckpoint()
      • 从类继承的方法 java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • 构造器详细资料

    • 方法详细资料

      • isComplete

        public boolean isComplete​(RepeatContext context)
        从接口复制的说明: CompletionPolicy
        Allow policy to signal completion according to internal state, without having to wait for the callback to complete.
        指定者:
        isComplete 在接口中 CompletionPolicy
        参数:
        context - the current batch context.
        返回:
        true if the batch should terminate.
      • start

        public RepeatContext start​(RepeatContext parent)
        从接口复制的说明: CompletionPolicy
        Create a new context for the execution of a batch. N.B. implementations should not return the parent from this method - they must create a new context to meet the specific needs of the policy. The best way to do this might be to override an existing implementation and use the RepeatContext to store state in its attributes.
        指定者:
        start 在接口中 CompletionPolicy
        参数:
        parent - the current context if one is already in progress.
        返回:
        a context object that can be used by the implementation to store internal state for a batch.