Package | Description |
---|---|
org.apache.flink.table.planner.plan.nodes.exec | |
org.apache.flink.table.planner.plan.nodes.exec.utils |
Modifier and Type | Method and Description |
---|---|
protected TransformationMetadata |
ExecNodeBase.createTransformationMeta(String operatorName,
ExecNodeConfig config) |
protected TransformationMetadata |
ExecNodeBase.createTransformationMeta(String operatorName,
String detailName,
String simplifiedName,
ExecNodeConfig config) |
Modifier and Type | Method and Description |
---|---|
static <I,O> OneInputTransformation<I,O> |
ExecNodeUtil.createOneInputTransformation(Transformation<I> input,
TransformationMetadata transformationMeta,
StreamOperator<O> operator,
TypeInformation<O> outputType,
int parallelism)
Create a
OneInputTransformation . |
static <I,O> OneInputTransformation<I,O> |
ExecNodeUtil.createOneInputTransformation(Transformation<I> input,
TransformationMetadata transformationMeta,
StreamOperator<O> operator,
TypeInformation<O> outputType,
int parallelism,
long memoryBytes)
Create a
OneInputTransformation with memoryBytes. |
static <I,O> OneInputTransformation<I,O> |
ExecNodeUtil.createOneInputTransformation(Transformation<I> input,
TransformationMetadata transformationMeta,
StreamOperatorFactory<O> operatorFactory,
TypeInformation<O> outputType,
int parallelism)
Create a
OneInputTransformation . |
static <I,O> OneInputTransformation<I,O> |
ExecNodeUtil.createOneInputTransformation(Transformation<I> input,
TransformationMetadata transformationMeta,
StreamOperatorFactory<O> operatorFactory,
TypeInformation<O> outputType,
int parallelism,
long memoryBytes)
Create a
OneInputTransformation with memoryBytes. |
static <I1,I2,O> TwoInputTransformation<I1,I2,O> |
ExecNodeUtil.createTwoInputTransformation(Transformation<I1> input1,
Transformation<I2> input2,
TransformationMetadata transformationMeta,
StreamOperatorFactory<O> operatorFactory,
TypeInformation<O> outputType,
int parallelism,
long memoryBytes)
Create a
TwoInputTransformation with memoryBytes. |
static <IN1,IN2,O> |
ExecNodeUtil.createTwoInputTransformation(Transformation<IN1> input1,
Transformation<IN2> input2,
TransformationMetadata transformationMeta,
TwoInputStreamOperator<IN1,IN2,O> operator,
TypeInformation<O> outputType,
int parallelism)
Create a
TwoInputTransformation with memoryBytes. |
static <IN1,IN2,O> |
ExecNodeUtil.createTwoInputTransformation(Transformation<IN1> input1,
Transformation<IN2> input2,
TransformationMetadata transformationMeta,
TwoInputStreamOperator<IN1,IN2,O> operator,
TypeInformation<O> outputType,
int parallelism,
long memoryBytes)
Create a
TwoInputTransformation with memoryBytes. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.