StatefulProcessorNode

StatefulProcessorNode is a concrete StreamsGraphNode (as a ProcessorGraphNode) that represents stateful operators of the following:

StatefulProcessorNode is created when:

StatefulProcessorNode extends the parent ProcessorGraphNode with the two state-related parameters - the state store names and a StoreBuilder.

Creating StatefulProcessorNode Instance

StatefulProcessorNode takes the following to be created:

  • Node name

  • ProcessorParameters<K, V>

  • Names of the state stores or a StoreBuilder

writeToTopology Method

void writeToTopology(
  InternalTopologyBuilder topologyBuilder)
Note
writeToTopology is part of the StreamsGraphNode Contract to…​FIXME.

writeToTopology requests the given InternalTopologyBuilder to add a processor (with the name and the ProcessorSupplier as defined by the ProcessorParameters).

With state store names given, writeToTopology requests the given InternalTopologyBuilder to connect them with the processor.

With a StoreBuilder given, writeToTopology requests the given InternalTopologyBuilder to add a state store (with the StoreBuilder and the processor).

results matching ""

    No results matching ""