public class KTableRepartitionMap<K,V,K1,V1> extends java.lang.Object implements KTableProcessorSupplier<K,V,KeyValue<K1,V1>>
Given the input, it can output at most two records (one mapped from old value and one mapped from new value).
Modifier and Type | Method and Description |
---|---|
void |
enableSendingOldValues() |
Processor<K,Change<V>> |
get()
Return a new
Processor instance. |
KTableValueGetterSupplier<K,KeyValue<K1,V1>> |
view() |
public Processor<K,Change<V>> get()
ProcessorSupplier
Processor
instance.public KTableValueGetterSupplier<K,KeyValue<K1,V1>> view()
public void enableSendingOldValues()
enableSendingOldValues
in interface KTableProcessorSupplier<K,V,KeyValue<K1,V1>>
java.lang.IllegalStateException
- since this method should never be called