ProcessorNodeFactory

ProcessorNodeFactory is a concrete NodeFactory that can build a processor node for a ProcessorSupplier and optional state stores.

Note
ProcessorNodeFactory is a private class.

ProcessorNodeFactory is created exclusively when InternalTopologyBuilder is requested to register a global state store or addProcessor.

ProcessorNodeFactory manages names of the state stores that a Processor can be associated with (as part of a ProcessorNode).

ProcessorNodeFactory can have state stores registered (by the name) (which happens when InternalTopologyBuilder is requested to register a global state store or connectProcessorAndStateStore).

build Factory Method

ProcessorNode build()
Note
build is part of NodeFactory Contract to…​FIXME.

build requests ProcessorSupplier to get a Processor and then creates a ProcessorNode with the name, the processor and the stateStoreNames.

Creating ProcessorNodeFactory Instance

ProcessorNodeFactory takes the following when created:

results matching ""

    No results matching ""