Skip to content

Latest commit

 

History

History
20 lines (13 loc) · 1.13 KB

kafka-streams-internals-StateStoreNode.adoc

File metadata and controls

20 lines (13 loc) · 1.13 KB

StateStoreNode

StateStoreNode is a concrete StreamsGraphNode that is created exclusively when InternalStreamsBuilder is requested to add a state store to a topology.

In other words, StateStoreNode represents StreamsBuilder.addStateStore operator.

StateStoreNode takes a single StoreBuilder to be created.

writeToTopology Method

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

writeToTopology simply requests the given InternalTopologyBuilder to add a state store (as the StoreBuilder).