Package org.apache.kafka.streams.kstream
Interface Initializer<VA>
-
- Type Parameters:
VA
- aggregate value type
public interface Initializer<VA>
TheInitializer
interface for creating an initial value in aggregations.Initializer
is 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 VA
apply()
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
-
-