Processor<K, V> get()ProcessorSupplier Contract
ProcessorSupplier is the abstraction of processor factories that can create (aka supply) a record processor.
ProcessorSupplier defines a single get method that can supply a record processor.
get is used when ProcessorNodeFactory is requested to build a ProcessorNode (and also for a description of ProcessorParameters).
| ProcessorSupplier | Description |
|---|---|
Represents KStream.branch operator |
|
KStreamFlatMap |
|
KStreamFlatMapValues |
|
KStreamGlobalKTableJoin |
|
KStreamJoinWindow |
|
KStreamKStreamJoin |
|
KStreamKTableJoin |
|
KStreamMap |
|
KStreamMapValues |
|
Represents KStream.foreach and KStream.peek operators |
|
KStreamPrint |
|
KTableProcessorSupplier |
|