Collection<Integer> |
SinkTransformationTranslator.translateForBatch(SinkTransformation<InputT,CommT,WriterStateT,GlobalCommT> transformation,
TransformationTranslator.Context context) |
protected Collection<Integer> |
MultiInputTransformationTranslator.translateForBatchInternal(AbstractMultipleInputTransformation<OUT> transformation,
TransformationTranslator.Context context) |
protected Collection<Integer> |
BroadcastStateTransformationTranslator.translateForBatchInternal(BroadcastStateTransformation<IN1,IN2,OUT> transformation,
TransformationTranslator.Context context) |
protected Collection<Integer> |
KeyedBroadcastStateTransformationTranslator.translateForBatchInternal(KeyedBroadcastStateTransformation<KEY,IN1,IN2,OUT> transformation,
TransformationTranslator.Context context) |
protected Collection<Integer> |
LegacySinkTransformationTranslator.translateForBatchInternal(LegacySinkTransformation<IN> transformation,
TransformationTranslator.Context context) |
protected Collection<Integer> |
LegacySourceTransformationTranslator.translateForBatchInternal(LegacySourceTransformation<OUT> transformation,
TransformationTranslator.Context context) |
Collection<Integer> |
OneInputTransformationTranslator.translateForBatchInternal(OneInputTransformation<IN,OUT> transformation,
TransformationTranslator.Context context) |
protected Collection<Integer> |
PartitionTransformationTranslator.translateForBatchInternal(PartitionTransformation<OUT> transformation,
TransformationTranslator.Context context) |
Collection<Integer> |
ReduceTransformationTranslator.translateForBatchInternal(ReduceTransformation<IN,KEY> transformation,
TransformationTranslator.Context context) |
protected Collection<Integer> |
SideOutputTransformationTranslator.translateForBatchInternal(SideOutputTransformation<OUT> transformation,
TransformationTranslator.Context context) |
protected Collection<Integer> |
SourceTransformationTranslator.translateForBatchInternal(SourceTransformation<OUT,SplitT,EnumChkT> transformation,
TransformationTranslator.Context context) |
protected Collection<Integer> |
TimestampsAndWatermarksTransformationTranslator.translateForBatchInternal(TimestampsAndWatermarksTransformation<IN> transformation,
TransformationTranslator.Context context) |
protected Collection<Integer> |
TwoInputTransformationTranslator.translateForBatchInternal(TwoInputTransformation<IN1,IN2,OUT> transformation,
TransformationTranslator.Context context) |
protected Collection<Integer> |
UnionTransformationTranslator.translateForBatchInternal(UnionTransformation<OUT> transformation,
TransformationTranslator.Context context) |
Collection<Integer> |
SinkTransformationTranslator.translateForStreaming(SinkTransformation<InputT,CommT,WriterStateT,GlobalCommT> transformation,
TransformationTranslator.Context context) |
protected Collection<Integer> |
MultiInputTransformationTranslator.translateForStreamingInternal(AbstractMultipleInputTransformation<OUT> transformation,
TransformationTranslator.Context context) |
protected Collection<Integer> |
BroadcastStateTransformationTranslator.translateForStreamingInternal(BroadcastStateTransformation<IN1,IN2,OUT> transformation,
TransformationTranslator.Context context) |
protected Collection<Integer> |
KeyedBroadcastStateTransformationTranslator.translateForStreamingInternal(KeyedBroadcastStateTransformation<KEY,IN1,IN2,OUT> transformation,
TransformationTranslator.Context context) |
protected Collection<Integer> |
LegacySinkTransformationTranslator.translateForStreamingInternal(LegacySinkTransformation<IN> transformation,
TransformationTranslator.Context context) |
protected Collection<Integer> |
LegacySourceTransformationTranslator.translateForStreamingInternal(LegacySourceTransformation<OUT> transformation,
TransformationTranslator.Context context) |
Collection<Integer> |
OneInputTransformationTranslator.translateForStreamingInternal(OneInputTransformation<IN,OUT> transformation,
TransformationTranslator.Context context) |
protected Collection<Integer> |
PartitionTransformationTranslator.translateForStreamingInternal(PartitionTransformation<OUT> transformation,
TransformationTranslator.Context context) |
Collection<Integer> |
ReduceTransformationTranslator.translateForStreamingInternal(ReduceTransformation<IN,KEY> transformation,
TransformationTranslator.Context context) |
protected Collection<Integer> |
SideOutputTransformationTranslator.translateForStreamingInternal(SideOutputTransformation<OUT> transformation,
TransformationTranslator.Context context) |
protected Collection<Integer> |
SourceTransformationTranslator.translateForStreamingInternal(SourceTransformation<OUT,SplitT,EnumChkT> transformation,
TransformationTranslator.Context context) |
protected Collection<Integer> |
TimestampsAndWatermarksTransformationTranslator.translateForStreamingInternal(TimestampsAndWatermarksTransformation<IN> transformation,
TransformationTranslator.Context context) |
protected Collection<Integer> |
TwoInputTransformationTranslator.translateForStreamingInternal(TwoInputTransformation<IN1,IN2,OUT> transformation,
TransformationTranslator.Context context) |
protected Collection<Integer> |
UnionTransformationTranslator.translateForStreamingInternal(UnionTransformation<OUT> transformation,
TransformationTranslator.Context context) |
protected Collection<Integer> |
AbstractTwoInputTransformationTranslator.translateInternal(Transformation<OUT> transformation,
Transformation<IN1> firstInputTransformation,
Transformation<IN2> secondInputTransformation,
StreamOperatorFactory<OUT> operatorFactory,
TypeInformation<?> keyTypeInfo,
KeySelector<IN1,?> firstKeySelector,
KeySelector<IN2,?> secondKeySelector,
TransformationTranslator.Context context) |