ProcessorNode¶

ProcessorNode is a "hosting environment" of a Processor in a processor topology.

Creating Instance¶

ProcessorNode takes the following to be created:

• Name
• Processor
• Names of the state stores

ProcessorNode is created when:

• ProcessorNodeFactory is requested to build a processor

Specialized ProcessorNodes¶

SourceNode and SinkNode are specialized ProcessorNodes.

Child ProcessorNodes¶

ProcessorNode defines children internal registry of child ProcessorNodes.

The children is empty when ProcessorNode is created.

A new ProcessorNode is added in addChild.

addChild¶

void addChild(
  ProcessorNode<KOut, VOut, ?, ?> child)

addChild adds a new ProcessorNode to the children and the childByName internal registries.

addChild is used when:

• InternalTopologyBuilder is requested to buildSinkNode and buildProcessorNode

children¶

List<ProcessorNode<KOut, VOut, ?, ?>> children()

children is used when:

• GlobalProcessorContextImpl is requested to forward a record
• ProcessorContextImpl is requested to forward a record
• ProcessorTopology is requested for text representation

Terminal Node¶

ProcessorNode is terminal when has got no children.

punctuate¶

void punctuate(
  long timestamp, 
  Punctuator punctuator)

punctuate requests the given Punctuator to punctuate (with the given timestamp).

punctuate is used when:

• StreamTask is requested to punctuate