Package org.apache.kafka.streams.kstream

Interface Initializer<VA>

Type Parameters:
VA - aggregate value type
public interface Initializer<VA>
The Initializer interface for creating an initial value in aggregations. Initializer is used in combination with Aggregator.
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

    Modifier and Type Method Description
    VA apply()
    Return the initial value for an aggregation.

  • Method Details

    • apply

      VA apply()
      Return the initial value for an aggregation.
      Returns:
      the initial value for an aggregation