public class KStreamPrint<K,V> extends java.lang.Object implements ProcessorSupplier<K,V>
Constructor and Description |
---|
KStreamPrint(ForeachAction<K,V> action) |
Modifier and Type | Method and Description |
---|---|
Processor<K,V> |
get()
Return a new
Processor instance. |
public KStreamPrint(ForeachAction<K,V> action)
public Processor<K,V> get()
ProcessorSupplier
Processor
instance.get
in interface ProcessorSupplier<K,V>
Processor
instance