VAgg
- aggregate value typepublic interface Initializer<VAgg>
Initializer
interface for creating an initial value in aggregations.
Initializer
is used in combination with Aggregator
.Aggregator
,
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)
Modifier and Type | Method and Description |
---|---|
VAgg |
apply()
Return the initial value for an aggregation.
|
VAgg apply()