public class DecimalSumWithRetractAggFunction extends AggregateFunction<BigDecimal,DecimalSumWithRetractAccumulator>
Constructor and Description |
---|
DecimalSumWithRetractAggFunction() |
Modifier and Type | Method and Description |
---|---|
void |
accumulate(DecimalSumWithRetractAccumulator acc,
Object value) |
DecimalSumWithRetractAccumulator |
createAccumulator()
Creates and init the Accumulator for this
AggregateFunction . |
TypeInformation<?> |
getAccumulatorType() |
BigDecimal |
getValue(DecimalSumWithRetractAccumulator acc)
Called every time when an aggregation result should be materialized.
|
void |
merge(DecimalSumWithRetractAccumulator acc,
Iterable<DecimalSumWithRetractAccumulator> its) |
void |
resetAccumulator(DecimalSumWithRetractAccumulator acc) |
void |
retract(DecimalSumWithRetractAccumulator acc,
Object value) |
requiresOver
close, functionIdentifier, open
public DecimalSumWithRetractAccumulator createAccumulator()
AggregateFunction
AggregateFunction
.
createAccumulator
in class AggregateFunction<BigDecimal,DecimalSumWithRetractAccumulator>
public void accumulate(DecimalSumWithRetractAccumulator acc, Object value)
public void retract(DecimalSumWithRetractAccumulator acc, Object value)
public BigDecimal getValue(DecimalSumWithRetractAccumulator acc)
AggregateFunction
getValue
in class AggregateFunction<BigDecimal,DecimalSumWithRetractAccumulator>
acc
- the accumulator which contains the current
aggregated resultspublic void merge(DecimalSumWithRetractAccumulator acc, Iterable<DecimalSumWithRetractAccumulator> its)
public void resetAccumulator(DecimalSumWithRetractAccumulator acc)
public TypeInformation<?> getAccumulatorType()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.