@Internal public class AlignedController extends Object implements CheckpointBarrierBehaviourController
Constructor and Description |
---|
AlignedController(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 AlignedController(CheckpointableInput... inputs)
public void barrierReceived(InputChannelInfo channelInfo, CheckpointBarrier barrier)
CheckpointBarrierBehaviourController
CheckpointBarrier
.barrierReceived
in interface CheckpointBarrierBehaviourController
public boolean preProcessFirstBarrier(InputChannelInfo channelInfo, CheckpointBarrier barrier)
CheckpointBarrierBehaviourController
CheckpointBarrierBehaviourController.barrierReceived(InputChannelInfo, CheckpointBarrier)
for that given checkpoint.preProcessFirstBarrier
in interface CheckpointBarrierBehaviourController
true
if checkpoint should be triggered.public boolean postProcessLastBarrier(InputChannelInfo channelInfo, CheckpointBarrier barrier) throws IOException
CheckpointBarrierBehaviourController
CheckpointBarrierBehaviourController.barrierReceived(InputChannelInfo, CheckpointBarrier)
for that given checkpoint.postProcessLastBarrier
in interface CheckpointBarrierBehaviourController
true
if checkpoint should be triggered.IOException
public void abortPendingCheckpoint(long cancelledId, CheckpointException exception) throws IOException
abortPendingCheckpoint
in interface CheckpointBarrierBehaviourController
IOException
public void obsoleteBarrierReceived(InputChannelInfo channelInfo, CheckpointBarrier barrier) throws IOException
obsoleteBarrierReceived
in interface CheckpointBarrierBehaviourController
IOException
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.