Package | Description |
---|---|
org.apache.flink.api.java | |
org.apache.flink.api.java.operators |
Modifier and Type | Method and Description |
---|---|
ReduceOperator<T> |
DataSet.maxBy(int... fields)
Selects an element with maximum value.
|
ReduceOperator<T> |
DataSet.minBy(int... fields)
Selects an element with minimum value.
|
ReduceOperator<T> |
DataSet.reduce(ReduceFunction<T> reducer)
Applies a Reduce transformation on a non-grouped
DataSet . |
Modifier and Type | Method and Description |
---|---|
ReduceOperator<T> |
UnsortedGrouping.maxBy(int... fields)
Applies a special case of a reduce transformation (maxBy) on a grouped
DataSet . |
ReduceOperator<T> |
UnsortedGrouping.minBy(int... fields)
Applies a special case of a reduce transformation (minBy) on a grouped
DataSet . |
ReduceOperator<T> |
UnsortedGrouping.reduce(ReduceFunction<T> reducer)
Applies a Reduce transformation on a grouped
DataSet . |
ReduceOperator<IN> |
ReduceOperator.setCombineHint(ReduceOperatorBase.CombineHint strategy)
Sets the strategy to use for the combine phase of the reduce.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.