Class | Description |
---|---|
CoFeedbackTransformation<F> |
This represents a feedback point in a topology.
|
FeedbackTransformation<T> |
This represents a feedback point in a topology.
|
OneInputTransformation<IN,OUT> |
This Transformation represents the application of a
OneInputStreamOperator to one input
Transformation . |
PartitionTransformation<T> |
This transformation represents a change of partitioning of the input elements.
|
PhysicalTransformation<T> |
A
Transformation that creates a physical operation. |
SelectTransformation<T> |
This transformation represents a selection of only certain upstream elements.
|
SideOutputTransformation<T> |
This transformation represents a selection of a side output of an upstream operation with a
given
OutputTag . |
SinkTransformation<T> |
This Transformation represents a Sink.
|
SourceTransformation<T> |
This represents a Source.
|
SplitTransformation<T> |
This transformation represents a split of one
DataStream into several DataStreams
using an OutputSelector . |
TwoInputTransformation<IN1,IN2,OUT> |
This Transformation represents the application of a
TwoInputStreamOperator to two input Transformations . |
UnionTransformation<T> |
This transformation represents a union of several input
Transformations . |
Enum | Description |
---|---|
ShuffleMode |
The shuffle mode defines the data exchange mode between operators.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.