public class LongAvgAggregate extends IntegralAvgAggregate<Object>
Constructor and Description |
---|
LongAvgAggregate() |
Modifier and Type | Method and Description |
---|---|
Object |
doEvaluate(Row buffer) |
void |
doPrepare(Object value,
Row partial) |
void |
initiate(Row partial)
Initiate the intermediate aggregate value in Row.
|
TypeInformation<?>[] |
intermediateDataType()
Intermediate aggregate value types.
|
void |
merge(Row partial,
Row buffer)
Merge intermediate aggregate data into aggregate buffer.
|
void |
prepare(Object value,
Row partial)
Transform the aggregate field value into intermediate aggregate data.
|
evaluate
partialCountIndex, partialSumIndex, setAggOffsetInRow, supportPartial
public TypeInformation<?>[] intermediateDataType()
Aggregate
intermediateDataType
in interface Aggregate<Object>
intermediateDataType
in class IntegralAvgAggregate<Object>
public void initiate(Row partial)
Aggregate
public void prepare(Object value, Row partial)
Aggregate
public void doPrepare(Object value, Row partial)
doPrepare
in class IntegralAvgAggregate<Object>
public void merge(Row partial, Row buffer)
Aggregate
public Object doEvaluate(Row buffer)
doEvaluate
in class IntegralAvgAggregate<Object>
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.