Class | Description |
---|---|
AbstractMultipleInputTransformation<OUT> |
Base class for transformations representing the application of a
MultipleInputStreamOperator to input Transformations . |
CoFeedbackTransformation<F> |
This represents a feedback point in a topology.
|
FeedbackTransformation<T> |
This represents a feedback point in a topology.
|
KeyedMultipleInputTransformation<OUT> |
AbstractMultipleInputTransformation implementation for keyed streams. |
LegacySourceTransformation<T> |
This represents a Source.
|
MultipleInputTransformation<OUT> |
AbstractMultipleInputTransformation implementation for non-keyed streams. |
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<OUT> |
A
PhysicalTransformation for 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–2021 The Apache Software Foundation. All rights reserved.