void init(ProcessorContext context)SourceNode
SourceNode is a ProcessorNode that…FIXME
SourceNode is created exclusively when SourceNodeFactory is requested to build a processor node (when…FIXME)
SourceNode gets a ProcessorContext when initialized. It is later used when SourceNode processes a record (and simply forwards it downstream).
init Method
|
Note
|
init is part of ProcessorNode Contract to…FIXME.
|
init…FIXME
Processing Record — process Method
void process(
K key,
V value)|
Note
|
process is part of ProcessorNode Contract to…FIXME.
|
process simply requests ProcessorContext to forward followed by informing the sourceNodeForwardSensor that a record was processed.
Creating SourceNode Instance
SourceNode takes the following when created:
SourceNode initializes the internal registries and counters.