@Internal public interface CheckpointBarrierBehaviourController
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
barrierReceived(InputChannelInfo, CheckpointBarrier) for that given checkpoint. |
boolean |
preProcessFirstBarrier(InputChannelInfo channelInfo,
CheckpointBarrier barrier)
Invoked once per checkpoint, before the first invocation of
barrierReceived(InputChannelInfo, CheckpointBarrier) for that given checkpoint. |
void barrierReceived(InputChannelInfo channelInfo, CheckpointBarrier barrier)
CheckpointBarrier
.boolean preProcessFirstBarrier(InputChannelInfo channelInfo, CheckpointBarrier barrier) throws IOException, CheckpointException
barrierReceived(InputChannelInfo, CheckpointBarrier)
for that given checkpoint.true
if checkpoint should be triggered.IOException
CheckpointException
boolean postProcessLastBarrier(InputChannelInfo channelInfo, CheckpointBarrier barrier) throws IOException
barrierReceived(InputChannelInfo, CheckpointBarrier)
for that given checkpoint.true
if checkpoint should be triggered.IOException
void abortPendingCheckpoint(long cancelledId, CheckpointException exception) throws IOException
IOException
void obsoleteBarrierReceived(InputChannelInfo channelInfo, CheckpointBarrier barrier) throws IOException
IOException
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.