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 <I1,I2,O> TwoInputTransformation<I1,I2,O> |
ExecNodeUtil.createTwoInputTransformation(Transformation<I1> input1,
Transformation<I2> input2,
String name,
String desc,
StreamOperatorFactory<O> operatorFactory,
TypeInformation<O> outputType,
int parallelism,
long memoryBytes)
Create a
TwoInputTransformation 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,
String name,
String desc,
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,
String name,
String desc,
TwoInputStreamOperator<IN1,IN2,O> operator,
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.