@Internal public class UnalignedController extends Object implements CheckpointBarrierBehaviourController
Constructor and Description |
---|
UnalignedController(SubtaskCheckpointCoordinator checkpointCoordinator,
CheckpointableInput... inputs) |
Modifier and Type | Method and Description |
---|---|
void |
abortPendingCheckpoint(long cancelledId,
CheckpointException exception) |
void |
barrierReceived(InputChannelInfo channelInfo,
CheckpointBarrier barrier)
Invoked per every received
CheckpointBarrier . |
void |
obsoleteBarrierReceived(InputChannelInfo channelInfo,
CheckpointBarrier barrier) |
boolean |
postProcessLastBarrier(InputChannelInfo channelInfo,
CheckpointBarrier barrier)
Invoked once per checkpoint, after the last invocation of
CheckpointBarrierBehaviourController.barrierReceived(InputChannelInfo, CheckpointBarrier) for that given checkpoint. |
boolean |
preProcessFirstBarrier(InputChannelInfo channelInfo,
CheckpointBarrier barrier)
Invoked once per checkpoint, before the first invocation of
CheckpointBarrierBehaviourController.barrierReceived(InputChannelInfo, CheckpointBarrier) for that given checkpoint. |
public UnalignedController(SubtaskCheckpointCoordinator checkpointCoordinator, CheckpointableInput... inputs)
public void barrierReceived(InputChannelInfo channelInfo, CheckpointBarrier barrier)
CheckpointBarrierBehaviourController
CheckpointBarrier
.barrierReceived
in interface CheckpointBarrierBehaviourController
public boolean preProcessFirstBarrier(InputChannelInfo channelInfo, CheckpointBarrier barrier) throws IOException, CheckpointException
CheckpointBarrierBehaviourController
CheckpointBarrierBehaviourController.barrierReceived(InputChannelInfo, CheckpointBarrier)
for that given checkpoint.preProcessFirstBarrier
in interface CheckpointBarrierBehaviourController
true
if checkpoint should be triggered.IOException
CheckpointException
public boolean postProcessLastBarrier(InputChannelInfo channelInfo, CheckpointBarrier barrier)
CheckpointBarrierBehaviourController
CheckpointBarrierBehaviourController.barrierReceived(InputChannelInfo, CheckpointBarrier)
for that given checkpoint.postProcessLastBarrier
in interface CheckpointBarrierBehaviourController
true
if checkpoint should be triggered.public void abortPendingCheckpoint(long cancelledId, CheckpointException exception)
abortPendingCheckpoint
in interface CheckpointBarrierBehaviourController
public void obsoleteBarrierReceived(InputChannelInfo channelInfo, CheckpointBarrier barrier)
obsoleteBarrierReceived
in interface CheckpointBarrierBehaviourController
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.