org.apache.flink.streaming.runtime.translators

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 translating transformations 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 and Description
AbstractTwoInputTransformationTranslator()

Method Summary

Modifier and Type	Method and 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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AbstractTwoInputTransformationTranslator

public AbstractTwoInputTransformationTranslator()

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)