Package | Description |
---|---|
org.apache.flink.streaming.runtime.io |
Modifier and Type | Class and Description |
---|---|
class |
CheckpointBarrierAligner
CheckpointBarrierAligner keep tracks of received CheckpointBarrier on given
channels and controls the alignment, by deciding which channels should be blocked and when to
release blocked channels. |
class |
CheckpointBarrierTracker
The
CheckpointBarrierTracker keeps track of what checkpoint barriers have been received from
which input channels. |
Constructor and Description |
---|
CheckpointedInputGate(InputGate inputGate,
BufferStorage bufferStorage,
CheckpointBarrierHandler barrierHandler) |
CheckpointedInputGate(InputGate inputGate,
BufferStorage bufferStorage,
CheckpointBarrierHandler barrierHandler,
int channelIndexOffset)
Creates a new checkpoint stream aligner.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.