Interface | Description |
---|---|
BufferBlocker |
The buffer blocker takes the buffers and events from a data stream and adds them in a sequence.
|
BufferOrEventSequence |
This class represents a sequence of buffers and events which are blocked by
CheckpointBarrierHandler . |
CheckpointBarrierHandler |
The CheckpointBarrierHandler reacts to checkpoint barrier arriving from the input channels.
|
Class | Description |
---|---|
BarrierBuffer |
The barrier buffer is
CheckpointBarrierHandler that blocks inputs with barriers until
all inputs have received the barrier for a given checkpoint. |
BarrierTracker |
The BarrierTracker keeps track of what checkpoint barriers have been received from
which input channels.
|
BlockingQueueBroker |
Broker for the BlockingQueue used in
StreamIterationHead and
StreamIterationTail for implementing feedback
streams. |
BufferSpiller | Deprecated |
BufferSpiller.SpilledBufferOrEventSequence | Deprecated |
CachedBufferBlocker |
The cached buffer blocker takes the buffers and events from a data stream and adds them to a memory queue.
|
CachedBufferBlocker.CachedBufferOrEventSequence |
This class represents a sequence of cached buffers and events, created by the
CachedBufferBlocker . |
InputGateUtil |
Utility for dealing with input gates.
|
InputProcessorUtil |
Utility for creating
CheckpointBarrierHandler based on checkpoint mode
for StreamInputProcessor and StreamTwoInputProcessor . |
RecordWriterOutput<OUT> |
Implementation of
Output that sends data using a RecordWriter . |
StreamInputProcessor<IN> |
Input reader for
OneInputStreamTask . |
StreamTwoInputProcessor<IN1,IN2> |
Input reader for
TwoInputStreamTask . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.