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 .The transformation consecutively calls a RichReduceFunction
until only a single element remains which is the result of the transformation. |
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 .The transformation consecutively calls a ReduceFunction
until only a single element remains which is the result of the transformation. |
ReduceOperator<T> |
UnsortedGrouping.minBy(int... fields)
Applies a special case of a reduce transformation (minBy) on a grouped
DataSet .The transformation consecutively calls a ReduceFunction
until only a single element remains which is the result of the transformation. |
ReduceOperator<T> |
UnsortedGrouping.reduce(ReduceFunction<T> reducer)
Applies a Reduce transformation on a grouped
DataSet .For each group, the transformation consecutively calls a RichReduceFunction
until only a single element for each group remains. |
ReduceOperator<IN> |
ReduceOperator.setCombineHint(ReduceOperatorBase.CombineHint strategy)
Sets the strategy to use for the combine phase of the reduce.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.