Uses of Class
org.apache.flink.streaming.api.transformations.ReduceTransformation
-
Packages that use ReduceTransformation Package Description org.apache.flink.streaming.runtime.translators -
-
Uses of ReduceTransformation in org.apache.flink.streaming.runtime.translators
Methods in org.apache.flink.streaming.runtime.translators with parameters of type ReduceTransformation Modifier and Type Method Description Collection<Integer>
ReduceTransformationTranslator. translateForBatchInternal(ReduceTransformation<IN,KEY> transformation, TransformationTranslator.Context context)
Collection<Integer>
ReduceTransformationTranslator. translateForStreamingInternal(ReduceTransformation<IN,KEY> transformation, TransformationTranslator.Context context)
-