Uses of Class
org.apache.flink.api.java.operators.ReduceOperator
-
Packages that use ReduceOperator Package Description org.apache.flink.api.java org.apache.flink.api.java.operators -
-
Uses of ReduceOperator in org.apache.flink.api.java
Methods in org.apache.flink.api.java that return ReduceOperator Modifier and Type Method Description ReduceOperator<T>DataSet. maxBy(int... fields)Deprecated.Selects an element with maximum value.ReduceOperator<T>DataSet. minBy(int... fields)Deprecated.Selects an element with minimum value.ReduceOperator<T>DataSet. reduce(org.apache.flink.api.common.functions.ReduceFunction<T> reducer)Deprecated.Applies a Reduce transformation on a non-groupedDataSet. -
Uses of ReduceOperator in org.apache.flink.api.java.operators
Methods in org.apache.flink.api.java.operators that return ReduceOperator Modifier and Type Method Description ReduceOperator<T>UnsortedGrouping. maxBy(int... fields)Deprecated.Applies a special case of a reduce transformation (maxBy) on a groupedDataSet.ReduceOperator<T>UnsortedGrouping. minBy(int... fields)Deprecated.Applies a special case of a reduce transformation (minBy) on a groupedDataSet.ReduceOperator<T>UnsortedGrouping. reduce(org.apache.flink.api.common.functions.ReduceFunction<T> reducer)Deprecated.Applies a Reduce transformation on a groupedDataSet.ReduceOperator<IN>ReduceOperator. setCombineHint(org.apache.flink.api.common.operators.base.ReduceOperatorBase.CombineHint strategy)Deprecated.Sets the strategy to use for the combine phase of the reduce.
-