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