Package | Description |
---|---|
org.apache.flink.api.common.operators.base | |
org.apache.flink.api.java.operators | |
org.apache.flink.api.scala |
Modifier and Type | Method and Description |
---|---|
ReduceOperatorBase.CombineHint |
ReduceOperatorBase.getCombineHint() |
static ReduceOperatorBase.CombineHint |
ReduceOperatorBase.CombineHint.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ReduceOperatorBase.CombineHint[] |
ReduceOperatorBase.CombineHint.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
void |
ReduceOperatorBase.setCombineHint(ReduceOperatorBase.CombineHint hint) |
Modifier and Type | Method and Description |
---|---|
ReduceOperator<IN> |
ReduceOperator.setCombineHint(ReduceOperatorBase.CombineHint strategy)
Sets the strategy to use for the combine phase of the reduce.
|
Modifier and Type | Method and Description |
---|---|
DataSet<T> |
GroupedDataSet.reduce(scala.Function2<T,T,T> fun,
ReduceOperatorBase.CombineHint strategy)
Special
reduce operation for explicitly telling the system what strategy to use for the
combine phase. |
DataSet<T> |
GroupedDataSet.reduce(ReduceFunction<T> reducer,
ReduceOperatorBase.CombineHint strategy)
Special
reduce operation for explicitly telling the system what strategy to use for the
combine phase. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.