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 <T> OneInputTransformation<T,T> |
ExecNodeUtil.createOneInputTransformation(Transformation<T> input,
String name,
StreamOperatorFactory<T> operatorFactory,
TypeInformation<T> outputType,
int parallelism,
long memoryBytes)
Create a
OneInputTransformation with memoryBytes. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.