Class AbstractTwoInputTransformationTranslator<IN1,IN2,OUT,OP extends Transformation<OUT>>
- java.lang.Object
-
- org.apache.flink.streaming.api.graph.SimpleTransformationTranslator<OUT,OP>
-
- org.apache.flink.streaming.runtime.translators.AbstractTwoInputTransformationTranslator<IN1,IN2,OUT,OP>
-
- All Implemented Interfaces:
TransformationTranslator<OUT,OP>
- Direct Known Subclasses:
BroadcastStateTransformationTranslator
,KeyedBroadcastStateTransformationTranslator
,PythonBroadcastStateTransformationTranslator
,PythonKeyedBroadcastStateTransformationTranslator
,TwoInputTransformationTranslator
@Internal public abstract class AbstractTwoInputTransformationTranslator<IN1,IN2,OUT,OP extends Transformation<OUT>> extends SimpleTransformationTranslator<OUT,OP>
A base class with functionality used during translatingtransformations
with two inputs.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.flink.streaming.api.graph.TransformationTranslator
TransformationTranslator.Context
-
-
Constructor Summary
Constructors Constructor Description AbstractTwoInputTransformationTranslator()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected Collection<Integer>
translateInternal(Transformation<OUT> transformation, Transformation<IN1> firstInputTransformation, Transformation<IN2> secondInputTransformation, StreamOperatorFactory<OUT> operatorFactory, TypeInformation<?> keyTypeInfo, KeySelector<IN1,?> firstKeySelector, KeySelector<IN2,?> secondKeySelector, TransformationTranslator.Context context)
-
Methods inherited from class org.apache.flink.streaming.api.graph.SimpleTransformationTranslator
translateForBatch, translateForBatchInternal, translateForStreaming, translateForStreamingInternal
-
-
-
-
Method Detail
-
translateInternal
protected Collection<Integer> translateInternal(Transformation<OUT> transformation, Transformation<IN1> firstInputTransformation, Transformation<IN2> secondInputTransformation, StreamOperatorFactory<OUT> operatorFactory, @Nullable TypeInformation<?> keyTypeInfo, @Nullable KeySelector<IN1,?> firstKeySelector, @Nullable KeySelector<IN2,?> secondKeySelector, TransformationTranslator.Context context)
-
-