StatefulProcessorNode¶

StatefulProcessorNode is a ProcessorGraphNode.

Creating Instance¶

StatefulProcessorNode takes the following to be created:

• Name
• ProcessorParameters
• State Stores
• KTableValueGetterSuppliers

StatefulProcessorNode is created when:

• CogroupedStreamAggregateBuilder is requested to getStatefulProcessorNode
• GroupedStreamAggregateBuilder is requested to build
• KGroupedTableImpl is requested to doAggregate
• KStreamImpl is requested to flatTransform, doTransformValues, doFlatTransformValues and process
• KTableImpl is requested to doJoinOnForeignKey and suppress

State Stores¶

StatefulProcessorNode can be given the names of the associated state stores directly or as StoreBuilders (together with the stores of the KTableValueGetterSuppliers) when created.

State Stores¶

StatefulProcessorNode can be given a StoreBuilder when created.