public class DecimalMinAggregate extends Object implements Aggregate<BigDecimal>
Constructor and Description |
---|
DecimalMinAggregate() |
Modifier and Type | Method and Description |
---|---|
BigDecimal |
evaluate(Row buffer)
Calculate the final aggregated result based on aggregate buffer.
|
void |
initiate(Row intermediate)
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.
|
protected int |
minIndex() |
void |
prepare(Object value,
Row partial)
Transform the aggregate field value into intermediate aggregate data.
|
void |
setAggOffsetInRow(int aggOffset)
Set the aggregate data offset in Row.
|
boolean |
supportPartial()
Whether aggregate function support partial aggregate.
|
protected int minIndex()
public TypeInformation<?>[] intermediateDataType()
Aggregate
intermediateDataType
in interface Aggregate<BigDecimal>
public void initiate(Row intermediate)
Aggregate
initiate
in interface Aggregate<BigDecimal>
intermediate
- The intermediate aggregate row to initiate.public void prepare(Object value, Row partial)
Aggregate
prepare
in interface Aggregate<BigDecimal>
value
- The value to insert into the intermediate aggregate row.partial
- The intermediate aggregate row into which the value is inserted.public void merge(Row partial, Row buffer)
Aggregate
merge
in interface Aggregate<BigDecimal>
partial
- The intermediate aggregate row to merge.buffer
- The aggregate buffer into which the intermedidate is merged.public BigDecimal evaluate(Row buffer)
Aggregate
evaluate
in interface Aggregate<BigDecimal>
buffer
- The aggregate buffer from which the final aggregate is computed.public boolean supportPartial()
Aggregate
supportPartial
in interface Aggregate<BigDecimal>
public void setAggOffsetInRow(int aggOffset)
Aggregate
setAggOffsetInRow
in interface Aggregate<BigDecimal>
aggOffset
- The offset of this aggregate in the intermediate aggregate rows.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.