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