@Internal public class AlternatingController extends Object implements CheckpointBarrierBehaviourController
Constructor and Description |
---|
AlternatingController(AlignedController alignedController,
UnalignedController unalignedController) |
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 AlternatingController(AlignedController alignedController, UnalignedController unalignedController)
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) 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.