public class KStreamAggregate<K,V,T> extends java.lang.Object implements KStreamAggProcessorSupplier<K,K,V,T>
Modifier and Type | Method and Description |
---|---|
void |
enableSendingOldValues() |
Processor<K,V> |
get()
Return a new
Processor instance. |
KTableValueGetterSupplier<K,T> |
view() |
public Processor<K,V> get()
ProcessorSupplier
Processor
instance.get
in interface ProcessorSupplier<K,V>
Processor
instancepublic void enableSendingOldValues()
enableSendingOldValues
in interface KStreamAggProcessorSupplier<K,K,V,T>
public KTableValueGetterSupplier<K,T> view()