Package | Description |
---|---|
org.apache.flink.streaming.runtime.translators | |
org.apache.flink.table.planner.plan.nodes.exec.utils |
Modifier and Type | Method and Description |
---|---|
protected Collection<Integer> |
TwoInputTransformationTranslator.translateForBatchInternal(TwoInputTransformation<IN1,IN2,OUT> transformation,
TransformationTranslator.Context context) |
protected Collection<Integer> |
TwoInputTransformationTranslator.translateForStreamingInternal(TwoInputTransformation<IN1,IN2,OUT> transformation,
TransformationTranslator.Context context) |
Modifier and Type | Method and Description |
---|---|
static <T> TwoInputTransformation<T,T,T> |
ExecNodeUtil.createTwoInputTransformation(Transformation<T> input1,
Transformation<T> input2,
String name,
StreamOperatorFactory<T> operatorFactory,
TypeInformation<T> outputType,
int parallelism,
long memoryBytes)
Create a
TwoInputTransformation with memoryBytes. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.