public class CountAggFunction extends AggregateFunction<Object,CountAccumulator>
Constructor and Description |
---|
CountAggFunction() |
Modifier and Type | Method and Description |
---|---|
void |
accumulate(CountAccumulator acc,
Object value) |
CountAccumulator |
createAccumulator()
Creates and init the Accumulator for this
AggregateFunction . |
TypeInformation<?> |
getAccumulatorType() |
TypeInformation<?> |
getResultType() |
long |
getValue(CountAccumulator acc) |
void |
merge(CountAccumulator acc,
Iterable<CountAccumulator> its) |
void |
resetAccumulator(CountAccumulator acc) |
void |
retract(CountAccumulator acc,
Object value) |
requiresOver
close, functionIdentifier, open
public void accumulate(CountAccumulator acc, Object value)
public void retract(CountAccumulator acc, Object value)
public long getValue(CountAccumulator acc)
public void merge(CountAccumulator acc, Iterable<CountAccumulator> its)
public CountAccumulator createAccumulator()
AggregateFunction
AggregateFunction
.
createAccumulator
in class AggregateFunction<Object,CountAccumulator>
public void resetAccumulator(CountAccumulator acc)
public TypeInformation<?> getAccumulatorType()
public TypeInformation<?> getResultType()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.