ProcessorNode is a "hosting environment" of a Processor in a processor topology.
ProcessorNode takes the following to be created:
- Names of the state stores
ProcessorNode is created when:
ProcessorNodeFactoryis requested to build a processor
children internal registry of child
children is empty when
ProcessorNode is created.
ProcessorNode is added in addChild.
void addChild( ProcessorNode<KOut, VOut, ?, ?> child)
addChild is used when:
List<ProcessorNode<KOut, VOut, ?, ?>> children()
children is used when:
GlobalProcessorContextImplis requested to forward a record
ProcessorContextImplis requested to forward a record
ProcessorTopologyis requested for text representation
ProcessorNode is terminal when has got no children.
void punctuate( long timestamp, Punctuator punctuator)
punctuate is used when:
StreamTaskis requested to punctuate