public class KStreamTransform<K,V,K1,V1> extends java.lang.Object implements ProcessorSupplier<K,V>
Modifier and Type | Class and Description |
---|---|
static class |
KStreamTransform.KStreamTransformProcessor<K1,V1,K2,V2> |
Constructor and Description |
---|
KStreamTransform(TransformerSupplier<? super K,? super V,? extends KeyValue<? extends K1,? extends V1>> transformerSupplier) |
Modifier and Type | Method and Description |
---|---|
Processor<K,V> |
get()
Return a new
Processor instance. |
public Processor<K,V> get()
ProcessorSupplier
Processor
instance.get
in interface ProcessorSupplier<K,V>
Processor
instance