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)
writeToTopology is part of the StreamsGraphNode Contract to…​FIXME.

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

results matching ""

    No results matching ""