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.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.