public class KStreamWindowAggregate<K,V,Agg,W extends Window> extends java.lang.Object implements KStreamAggProcessorSupplier<K,Windowed<K>,V,Agg>
Constructor and Description |
---|
KStreamWindowAggregate(Windows<W> windows,
java.lang.String storeName,
Initializer<Agg> initializer,
Aggregator<? super K,? super V,Agg> aggregator) |
Modifier and Type | Method and Description |
---|---|
void |
enableSendingOldValues() |
Processor<K,V> |
get()
Return a new
Processor instance. |
KTableValueGetterSupplier<Windowed<K>,Agg> |
view() |
Windows<W> |
windows() |
public KStreamWindowAggregate(Windows<W> windows, java.lang.String storeName, Initializer<Agg> initializer, Aggregator<? super K,? super V,Agg> aggregator)
public Processor<K,V> get()
ProcessorSupplier
Processor
instance.get
in interface ProcessorSupplier<K,V>
Processor
instancepublic void enableSendingOldValues()
enableSendingOldValues
in interface KStreamAggProcessorSupplier<K,Windowed<K>,V,Agg>