Modifier and Type | Method and Description |
---|---|
protected GroupReduceOperatorBase<?,OUT,?> |
GroupReduceOperator.translateToDataFlow(Operator<IN> input) |
protected GroupReduceOperatorBase<IN,IN,GroupReduceFunction<IN,IN>> |
AggregateOperator.translateToDataFlow(Operator<IN> input) |
Modifier and Type | Class and Description |
---|---|
class |
PlanUnwrappingReduceGroupOperator<IN,OUT,K>
A reduce operator that takes 2-tuples (key-value pairs), and applies the group reduce operation only
on the unwrapped values.
|
class |
PlanUnwrappingSortedReduceGroupOperator<IN,OUT,K1,K2>
A reduce operator that takes 3-tuples (groupKey, sortKey, value), and applies the sorted group reduce
operation only on the unwrapped values.
|
Modifier and Type | Method and Description |
---|---|
protected GroupReduceOperatorBase<IN,IN,GroupReduceFunction<IN,IN>> |
ScalaAggregateOperator.translateToDataFlow(Operator<IN> input) |
Modifier and Type | Method and Description |
---|---|
GroupReduceOperatorBase<?,?,?> |
GroupReduceNode.getOperator()
Gets the operator represented by this optimizer node.
|
Constructor and Description |
---|
GroupReduceNode(GroupReduceOperatorBase<?,?,?> operator)
Creates a new optimizer node for the given operator.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.