Package | Description |
---|---|
org.apache.flink.streaming.runtime.translators | |
org.apache.flink.table.planner.plan.nodes.exec.utils |
Modifier and Type | Method and Description |
---|---|
Collection<Integer> |
OneInputTransformationTranslator.translateForBatchInternal(OneInputTransformation<IN,OUT> transformation,
TransformationTranslator.Context context) |
Collection<Integer> |
OneInputTransformationTranslator.translateForStreamingInternal(OneInputTransformation<IN,OUT> transformation,
TransformationTranslator.Context context) |
Modifier and Type | Method and Description |
---|---|
static <I,O> OneInputTransformation<I,O> |
ExecNodeUtil.createOneInputTransformation(Transformation<I> input,
String name,
String desc,
StreamOperator<O> operator,
TypeInformation<O> outputType,
int parallelism)
Create a
OneInputTransformation . |
static <I,O> OneInputTransformation<I,O> |
ExecNodeUtil.createOneInputTransformation(Transformation<I> input,
String name,
String desc,
StreamOperatorFactory<O> operatorFactory,
TypeInformation<O> outputType,
int parallelism)
Create a
OneInputTransformation . |
static <I,O> OneInputTransformation<I,O> |
ExecNodeUtil.createOneInputTransformation(Transformation<I> input,
String name,
String desc,
StreamOperatorFactory<O> operatorFactory,
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,
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. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.