void writeToTopology(
InternalTopologyBuilder topologyBuilder)TableSourceNode
TableSourceNode is a concrete StreamsGraphNode (as a StreamSourceNode) that is created (using StreamStreamJoinNode.build 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.
writeToTopology Method
|
Note
|
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 simply creates a new TableSourceNode.
|
Note
|
build is used exclusively when InternalStreamsBuilder is requested to table and globalTable.
|