Package org.apache.flink.streaming.runtime.translators

Class Summary

Class	Description
AbstractTwoInputTransformationTranslator<IN1,IN2,OUT,OP extends Transformation<OUT>>	A base class with functionality used during translating transformations with two inputs.
BroadcastStateTransformationTranslator<IN1,IN2,OUT>	A TransformationTranslator for the BroadcastStateTransformation.
KeyedBroadcastStateTransformationTranslator<KEY,IN1,IN2,OUT>	A TransformationTranslator for the KeyedBroadcastStateTransformation.
LegacySinkTransformationTranslator<IN>	A TransformationTranslator for the LegacySinkTransformation.
LegacySourceTransformationTranslator<OUT>	A TransformationTranslator for the LegacySourceTransformation.
MultiInputTransformationTranslator<OUT>	A TransformationTranslator for the MultipleInputTransformation and the KeyedMultipleInputTransformation.
OneInputTransformationTranslator<IN,OUT>	A TransformationTranslator for the OneInputTransformation.
PartitionTransformationTranslator<OUT>	A TransformationTranslator for the PartitionTransformation.
ReduceTransformationTranslator<IN,KEY>	A TransformationTranslator for the ReduceTransformation.
SideOutputTransformationTranslator<OUT>	A TransformationTranslator for the SideOutputTransformation.
SinkTransformationTranslator<InputT,CommT,WriterStateT,GlobalCommT>	A TransformationTranslator for the SinkTransformation.
SourceTransformationTranslator<OUT,SplitT extends SourceSplit,EnumChkT>	A TransformationTranslator for the SourceTransformation.
TimestampsAndWatermarksTransformationTranslator<IN>	A TransformationTranslator for the TimestampsAndWatermarksTransformation.
TwoInputTransformationTranslator<IN1,IN2,OUT>	A TransformationTranslator for the TwoInputTransformation.
UnionTransformationTranslator<OUT>	A TransformationTranslator for the UnionTransformation.