Package org.apache.kafka.streams.kstream
Interface Initializer<VA>
-
- Type Parameters:
VA- aggregate value type
public interface Initializer<VA>TheInitializerinterface for creating an initial value in aggregations.Initializeris used in combination withAggregator.- See Also:
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)
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description VAapply()Return the initial value for an aggregation.
-
-
-
Method Detail
-
apply
VA apply()
Return the initial value for an aggregation.- Returns:
- the initial value for an aggregation
-
-