public class AggregateReduceCombineFunction extends AggregateReduceGroupFunction implements CombineFunction<Row,Row>
GroupReduceOperator
and
GroupCombineOperator
Constructor and Description |
---|
AggregateReduceCombineFunction(Aggregate<?>[] aggregates,
scala.Tuple2<Object,Object>[] groupKeysMapping,
scala.Tuple2<Object,Object>[] aggregateMapping,
int intermediateRowArity,
int finalRowArity) |
Modifier and Type | Method and Description |
---|---|
Row |
combine(Iterable<Row> records)
For sub-grouped intermediate aggregate Rows, merge all of them into aggregate buffer,
|
aggregateBuffer, open, reduce
close, getIterationRuntimeContext, getRuntimeContext, setRuntimeContext
public Row combine(Iterable<Row> records)
combine
in interface CombineFunction<Row,Row>
records
- Sub-grouped intermediate aggregate Rows iterator.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.