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