TableSourceNode is a concrete StreamsGraphNode (as a StreamSourceNode) that is created (using method) when InternalStreamsBuilder is requested to add a KTable and a GlobalKTable to a topology.

In other words, TableSourceNode represents StreamsBuilder.table and StreamsBuilder.globalTable operators.

Creating TableSourceNode Instance

TableSourceNode takes the following to be created:

writeToTopology Method

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

writeToTopology creates a KeyValueStoreMaterializer and requests it to materialize (to a StoreBuilder of KeyValueStore).

writeToTopology branches off per isGlobalKTable flag.

When the isGlobalKTable flag is enabled (true), writeToTopology requests the given InternalTopologyBuilder to add a global key-value state store (to a topology).

When the isGlobalKTable flag is disabled (false), writeToTopology…​FIXME

Creating TableSourceNode — build Method

TableSourceNode<K, V> build()
build is used exclusively when InternalStreamsBuilder is requested to table and globalTable.

results matching ""

    No results matching ""