K - key typeV - input value typeVA - aggregate value typepublic interface Aggregator<K,V,VA>
Aggregator interface for aggregating values of the given key.
This is a generalization of Reducer and allows to have different types for input value and aggregation
result.
Aggregator is used in combination with Initializer that provides an initial aggregation value.
Aggregator can be used to implement aggregation functions like count.
Initializer,
KGroupedStream.aggregate(Initializer, Aggregator),
KGroupedStream.aggregate(Initializer, Aggregator, Materialized),
TimeWindowedKStream.aggregate(Initializer, Aggregator),
TimeWindowedKStream.aggregate(Initializer, Aggregator, Materialized),
SessionWindowedKStream.aggregate(Initializer, Aggregator, Merger),
SessionWindowedKStream.aggregate(Initializer, Aggregator, Merger, Materialized),
Reducer| Modifier and Type | Method and Description |
|---|---|
VA |
apply(K key,
V value,
VA aggregate)
Compute a new aggregate from the key and value of a record and the current aggregate of the same key.
|