NodeFactory Contract

NodeFactory is the abstraction of processor node factories that can build and describe a processor node.

NodeFactory takes the following to be created:

  • Name of a processor to be built

  • Node predecessors (by their names) that a processor will be a child of

Note
 NodeFactory is a Java private static abstract class of InternalTopologyBuilder and cannot be created directly. It is created indirectly for the concrete processor node factories and only for and by InternalTopologyBuilder.
Table 1. NodeFactory Contract
Method Description

build

 
ProcessorNode build()

Builds a processor node

Used exclusively when InternalTopologyBuilder is requested to build a topology of processor nodes (aka processor topology)

describe

 
AbstractNode describe()

Describes a processor node (using AbstractNode)

Used exclusively when InternalTopologyBuilder is requested to describeSubtopology (when requested to describe a topology)
Table 2. NodeFactories
NodeFactory Description

ProcessorNodeFactory

SinkNodeFactory

Factory of SinkNodes

SourceNodeFactory

results matching ""

    No results matching ""