Interface | Description |
---|---|
BufferOrEventSequence |
This class represents a sequence of buffers and events which are blocked by
CheckpointedInputGate . |
BufferStorage |
The
BufferStorage takes the buffers and events from a data stream and adds them in a sequence. |
StreamInputProcessor |
Interface for processing records by
StreamTask . |
StreamTaskInput |
Basic interface for inputs of stream operators.
|
Class | Description |
---|---|
AbstractBufferStorage |
A default abstract based class for
BufferStorage implementations. |
BlockingQueueBroker |
Broker for the BlockingQueue used in
StreamIterationHead and
StreamIterationTail for implementing feedback
streams. |
BufferSpiller | Deprecated |
BufferSpiller.SpilledBufferOrEventSequence | Deprecated |
CachedBufferStorage |
The
CachedBufferStorage takes the buffers and events from a data stream and adds them to
a memory queue. |
CachedBufferStorage.CachedBufferOrEventSequence |
This class represents a sequence of cached buffers and events, created by the
CachedBufferStorage . |
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. |
CheckpointBarrierHandler |
The
CheckpointBarrierHandler reacts to checkpoint barrier arriving from the input channels. |
CheckpointBarrierTracker |
The
CheckpointBarrierTracker keeps track of what checkpoint barriers have been received from
which input channels. |
CheckpointedInputGate |
The
CheckpointedInputGate uses CheckpointBarrierHandler to handle incoming
CheckpointBarrier from the InputGate . |
EmptyBufferStorage |
Always empty implementation of
BufferStorage . |
InputGateUtil |
Utility for dealing with input gates.
|
InputProcessorUtil |
Utility for creating
CheckpointedInputGate based on checkpoint mode
for StreamOneInputProcessor and StreamTwoInputProcessor . |
LinkedBufferStorage |
Implementation of
BufferStorage that links two BufferStorage together. |
RecordWriterOutput<OUT> |
Implementation of
Output that sends data using a RecordWriter . |
StreamOneInputProcessor<IN> |
Input reader for
OneInputStreamTask . |
StreamTaskNetworkInput |
Implementation of
StreamTaskInput that wraps an input from network taken from CheckpointedInputGate . |
StreamTwoInputProcessor<IN1,IN2> |
Input reader for
TwoInputStreamTask . |
StreamTwoInputSelectableProcessor<IN1,IN2> |
Input reader for
TwoInputSelectableStreamTask
in the case that the operator is InputSelectable. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.