NodeFactory¶

NodeFactory<KIn, VIn, KOut, VOut> is an abstraction of named node factories (with predecessors).

NodeFactory is a private static abstract class of InternalTopologyBuilder.

Contract¶

build¶

ProcessorNode<KIn, VIn, KOut, VOut> build()

Used when:

• InternalTopologyBuilder is requested to build a ProcessorTopology

describe¶

AbstractNode describe()

Used when:

• InternalTopologyBuilder is requested to describeSubtopology

Implementations¶

• ProcessorNodeFactory
• SinkNodeFactory
• SourceNodeFactory

Creating Instance¶

NodeFactory takes the following to be created:

• Name
• Predecessors