Package | Description |
---|---|
org.apache.flink.streaming.runtime.io |
Modifier and Type | Class and Description |
---|---|
class |
BarrierBuffer
The barrier buffer is
CheckpointBarrierHandler that blocks inputs with barriers until
all inputs have received the barrier for a given checkpoint. |
class |
BarrierTracker
The BarrierTracker keeps track of what checkpoint barriers have been received from
which input channels.
|
Modifier and Type | Method and Description |
---|---|
static CheckpointBarrierHandler |
InputProcessorUtil.createCheckpointBarrierHandler(StreamTask<?,?> checkpointedTask,
CheckpointingMode checkpointMode,
IOManager ioManager,
InputGate inputGate,
Configuration taskManagerConfig) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.