Modifier and Type | Method and Description |
---|---|
abstract Collection<Transformation<?>> |
Transformation.getTransitivePredecessors()
Returns all transitive predecessor
Transformation s of this Transformation . |
Modifier and Type | Field and Description |
---|---|
protected Transformation<T> |
DataStream.transformation |
Modifier and Type | Method and Description |
---|---|
Transformation<T> |
BroadcastStream.getTransformation() |
Transformation<T> |
DataStream.getTransformation()
Returns the
Transformation that represents the operation that logically creates this
DataStream . |
Constructor and Description |
---|
DataStream(StreamExecutionEnvironment environment,
Transformation<T> transformation)
Create a new
DataStream in the given execution environment with partitioning set to
forward by default. |
SingleOutputStreamOperator(StreamExecutionEnvironment environment,
Transformation<T> transformation) |
Modifier and Type | Field and Description |
---|---|
protected List<Transformation<?>> |
StreamExecutionEnvironment.transformations |
Modifier and Type | Method and Description |
---|---|
void |
StreamExecutionEnvironment.addOperator(Transformation<?> transformation)
Adds an operator to the list of operators that should be executed when calling
StreamExecutionEnvironment.execute() . |
Constructor and Description |
---|
StreamGraphGenerator(List<Transformation<?>> transformations,
ExecutionConfig executionConfig,
CheckpointConfig checkpointConfig) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractMultipleInputTransformation<OUT>
Base class for transformations representing the application of a
MultipleInputStreamOperator to input Transformations . |
class |
CoFeedbackTransformation<F>
This represents a feedback point in a topology.
|
class |
FeedbackTransformation<T>
This represents a feedback point in a topology.
|
class |
KeyedMultipleInputTransformation<OUT>
AbstractMultipleInputTransformation implementation for keyed streams. |
class |
LegacySourceTransformation<T>
This represents a Source.
|
class |
MultipleInputTransformation<OUT>
AbstractMultipleInputTransformation implementation for non-keyed streams. |
class |
OneInputTransformation<IN,OUT>
This Transformation represents the application of a
OneInputStreamOperator to one input Transformation . |
class |
PartitionTransformation<T>
This transformation represents a change of partitioning of the input elements.
|
class |
PhysicalTransformation<T>
A
Transformation that creates a physical operation. |
class |
SelectTransformation<T>
This transformation represents a selection of only certain upstream elements.
|
class |
SideOutputTransformation<T>
This transformation represents a selection of a side output of an upstream operation with a given
OutputTag . |
class |
SinkTransformation<T>
This Transformation represents a Sink.
|
class |
SourceTransformation<OUT>
A
PhysicalTransformation for Source . |
class |
SplitTransformation<T>
This transformation represents a split of one
DataStream into several DataStreams using an
OutputSelector . |
class |
TwoInputTransformation<IN1,IN2,OUT>
This Transformation represents the application of a
TwoInputStreamOperator to two input
Transformations . |
class |
UnionTransformation<T>
This transformation represents a union of several input
Transformations . |
Modifier and Type | Field and Description |
---|---|
protected List<Transformation<?>> |
AbstractMultipleInputTransformation.inputs |
Modifier and Type | Method and Description |
---|---|
Transformation<T> |
PartitionTransformation.getInput()
Returns the input
Transformation of this SinkTransformation . |
Transformation<T> |
SelectTransformation.getInput()
Returns the input
Transformation . |
Transformation<T> |
SplitTransformation.getInput()
Returns the input
Transformation . |
Transformation<T> |
FeedbackTransformation.getInput()
Returns the input
Transformation of this FeedbackTransformation . |
Transformation<T> |
SinkTransformation.getInput()
Returns the input
Transformation of this SinkTransformation . |
Transformation<IN> |
OneInputTransformation.getInput()
Returns the input
Transformation of this OneInputTransformation . |
Transformation<?> |
SideOutputTransformation.getInput()
Returns the input
Transformation . |
Transformation<IN1> |
TwoInputTransformation.getInput1()
Returns the first input
Transformation of this TwoInputTransformation . |
Transformation<IN2> |
TwoInputTransformation.getInput2()
Returns the second input
Transformation of this TwoInputTransformation . |
Modifier and Type | Method and Description |
---|---|
void |
CoFeedbackTransformation.addFeedbackEdge(Transformation<F> transform)
Adds a feedback edge.
|
void |
FeedbackTransformation.addFeedbackEdge(Transformation<T> transform)
Adds a feedback edge.
|
MultipleInputTransformation<OUT> |
MultipleInputTransformation.addInput(Transformation<?> input) |
KeyedMultipleInputTransformation<OUT> |
KeyedMultipleInputTransformation.addInput(Transformation<?> input,
KeySelector<?,?> keySelector) |
Constructor and Description |
---|
FeedbackTransformation(Transformation<T> input,
Long waitTime)
Creates a new
FeedbackTransformation from the given input. |
OneInputTransformation(Transformation<IN> input,
String name,
OneInputStreamOperator<IN,OUT> operator,
TypeInformation<OUT> outputType,
int parallelism)
Creates a new
OneInputTransformation from the given input and operator. |
OneInputTransformation(Transformation<IN> input,
String name,
StreamOperatorFactory<OUT> operatorFactory,
TypeInformation<OUT> outputType,
int parallelism) |
PartitionTransformation(Transformation<T> input,
StreamPartitioner<T> partitioner)
Creates a new
PartitionTransformation from the given input and StreamPartitioner . |
PartitionTransformation(Transformation<T> input,
StreamPartitioner<T> partitioner,
ShuffleMode shuffleMode)
Creates a new
PartitionTransformation from the given input and StreamPartitioner . |
SelectTransformation(Transformation<T> input,
List<String> selectedNames)
Creates a new
SelectionTransformation from the given input that only selects the
streams with the selected names. |
SideOutputTransformation(Transformation<?> input,
OutputTag<T> tag) |
SinkTransformation(Transformation<T> input,
String name,
StreamOperatorFactory<Object> operatorFactory,
int parallelism) |
SinkTransformation(Transformation<T> input,
String name,
StreamSink<T> operator,
int parallelism)
Creates a new
SinkTransformation from the given input Transformation . |
SplitTransformation(Transformation<T> input,
OutputSelector<T> outputSelector)
Creates a new
SplitTransformation from the given input and OutputSelector . |
TwoInputTransformation(Transformation<IN1> input1,
Transformation<IN2> input2,
String name,
StreamOperatorFactory<OUT> operatorFactory,
TypeInformation<OUT> outputType,
int parallelism) |
TwoInputTransformation(Transformation<IN1> input1,
Transformation<IN2> input2,
String name,
StreamOperatorFactory<OUT> operatorFactory,
TypeInformation<OUT> outputType,
int parallelism) |
TwoInputTransformation(Transformation<IN1> input1,
Transformation<IN2> input2,
String name,
TwoInputStreamOperator<IN1,IN2,OUT> operator,
TypeInformation<OUT> outputType,
int parallelism)
Creates a new
TwoInputTransformation from the given inputs and operator. |
TwoInputTransformation(Transformation<IN1> input1,
Transformation<IN2> input2,
String name,
TwoInputStreamOperator<IN1,IN2,OUT> operator,
TypeInformation<OUT> outputType,
int parallelism)
Creates a new
TwoInputTransformation from the given inputs and operator. |
Constructor and Description |
---|
UnionTransformation(List<Transformation<T>> inputs)
Creates a new
UnionTransformation from the given input Transformations . |
Modifier and Type | Method and Description |
---|---|
protected List<Transformation<?>> |
TableEnvironmentImpl.translateAndClearBuffer()
Translate the buffered operations to Transformations, and clear the buffer.
|
Modifier and Type | Method and Description |
---|---|
List<Transformation<?>> |
Planner.translate(List<ModifyOperation> modifyOperations)
Converts a relational tree of
ModifyOperation s into a set of runnable Transformation s. |
Modifier and Type | Method and Description |
---|---|
Pipeline |
Executor.createPipeline(List<Transformation<?>> transformations,
TableConfig tableConfig,
String jobName)
Translates the given transformations to a Pipeline.
|
Modifier and Type | Method and Description |
---|---|
Pipeline |
StreamExecutor.createPipeline(List<Transformation<?>> transformations,
TableConfig tableConfig,
String jobName) |
Modifier and Type | Method and Description |
---|---|
Pipeline |
BatchExecutor.createPipeline(List<Transformation<?>> transformations,
TableConfig tableConfig,
String jobName) |
Pipeline |
StreamExecutor.createPipeline(List<Transformation<?>> transformations,
TableConfig tableConfig,
String jobName) |
Modifier and Type | Method and Description |
---|---|
static StreamGraph |
ExecutorUtils.generateStreamGraph(StreamExecutionEnvironment execEnv,
List<Transformation<?>> transformations)
Generate
StreamGraph by StreamGraphGenerator . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.