Uses of Class
org.apache.flink.api.java.operators.GroupReduceOperator
-
Packages that use GroupReduceOperator Package Description org.apache.flink.api.java org.apache.flink.api.java.operators -
-
Uses of GroupReduceOperator in org.apache.flink.api.java
Methods in org.apache.flink.api.java that return GroupReduceOperator Modifier and Type Method Description GroupReduceOperator<T,T>DataSet. first(int n)Deprecated.Returns a new set containing the first n elements in thisDataSet.<R> GroupReduceOperator<T,R>DataSet. reduceGroup(org.apache.flink.api.common.functions.GroupReduceFunction<T,R> reducer)Deprecated.Applies a GroupReduce transformation on a non-groupedDataSet. -
Uses of GroupReduceOperator in org.apache.flink.api.java.operators
Methods in org.apache.flink.api.java.operators that return GroupReduceOperator Modifier and Type Method Description GroupReduceOperator<T,T>SortedGrouping. first(int n)Deprecated.Returns a new set containing the first n elements in this grouped and sortedDataSet.GroupReduceOperator<T,T>UnsortedGrouping. first(int n)Deprecated.Returns a new set containing the first n elements in this groupedDataSet.<R> GroupReduceOperator<T,R>SortedGrouping. reduceGroup(org.apache.flink.api.common.functions.GroupReduceFunction<T,R> reducer)Deprecated.Applies a GroupReduce transformation on a grouped and sortedDataSet.<R> GroupReduceOperator<T,R>UnsortedGrouping. reduceGroup(org.apache.flink.api.common.functions.GroupReduceFunction<T,R> reducer)Deprecated.Applies a GroupReduce transformation on a groupedDataSet.GroupReduceOperator<IN,OUT>GroupReduceOperator. setCombinable(boolean combinable)Deprecated.
-