void process(final K key, final V value)SinkNode — ProcessorNode with no Child Nodes
SinkNode is a custom ProcessorNode with no child processor nodes.
SinkNode is created exclusively when SinkNodeFactory is requested to build a processor node (when InternalTopologyBuilder is requested to build a topology of processor nodes).
SinkNode uses a TopicNameExtractor for dynamic routing when processing a record.
Processing Record — process Method
|
Note
|
process is part of ProcessorNode Contract to process a record.
|
process…FIXME
Adding Child Processor Node — addChild Method
void addChild(final ProcessorNode<?, ?> child)|
Note
|
addChild is part of ProcessorNode Contract to add a child processor node.
|
addChild simply throws an UnsupportedOperationException with the following message:
sink node does not allow addChild Initializing Processor Node — init Method
void init(final ProcessorContext context)|
Note
|
init is part of ProcessorNode Contract to…FIXME.
|
init…FIXME
Describing Itself (Textual Representation) — toString Method
void toString(final ProcessorContext context)|
Note
|
toString is part of ProcessorNode Contract for the human-friendly / textual representation of a ProcessorNode.
|
toString…FIXME