protected void |
CheckpointBarrierHandler.notifyCheckpoint(CheckpointBarrier checkpointBarrier,
long bufferedBytes,
long alignmentDurationNanos) |
boolean |
CheckpointBarrierAligner.processBarrier(CheckpointBarrier receivedBarrier,
int channelIndex,
long bufferedBytes) |
boolean |
CheckpointBarrierTracker.processBarrier(CheckpointBarrier receivedBarrier,
int channelIndex,
long bufferedBytes) |
abstract boolean |
CheckpointBarrierHandler.processBarrier(CheckpointBarrier receivedBarrier,
int channelIndex,
long bufferedBytes) |