Package | Description |
---|---|
org.apache.flink.api.java | |
org.apache.flink.api.java.operators |
Modifier and Type | Method and Description |
---|---|
GroupReduceOperator<T,T> |
DataSet.first(int n)
Returns a new set containing the first n elements in this
DataSet . |
<R> GroupReduceOperator<T,R> |
DataSet.reduceGroup(GroupReduceFunction<T,R> reducer)
Applies a GroupReduce transformation on a non-grouped
DataSet . |
Modifier and Type | Method and Description |
---|---|
GroupReduceOperator<T,T> |
SortedGrouping.first(int n)
Returns a new set containing the first n elements in this grouped and sorted
DataSet . |
GroupReduceOperator<T,T> |
UnsortedGrouping.first(int n)
Returns a new set containing the first n elements in this grouped
DataSet . |
<R> GroupReduceOperator<T,R> |
SortedGrouping.reduceGroup(GroupReduceFunction<T,R> reducer)
Applies a GroupReduce transformation on a grouped and sorted
DataSet . |
<R> GroupReduceOperator<T,R> |
UnsortedGrouping.reduceGroup(GroupReduceFunction<T,R> reducer)
Applies a GroupReduce transformation on a grouped
DataSet . |
GroupReduceOperator<IN,OUT> |
GroupReduceOperator.setCombinable(boolean combinable) |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.