KStreamAggregate¶

KStreamAggregate<K, V, T> is a KStreamAggProcessorSupplier.

Creating Instance¶

KStreamAggregate takes the following to be created:

• Name of a State Store
• Initializer (of T values)
• Aggregator<? super K, ? super V, T>

KStreamAggregate is created when:

• CogroupedStreamAggregateBuilder is requested to build (a KTable)
• KGroupedStreamImpl is requested to aggregate and doCount