TableSourceNode¶

TableSourceNode is a SourceGraphNode.

Creating Instance¶

TableSourceNode takes the following to be created:

• Node name
• Source name
• Topic
• ConsumedInternal<K, V>
• MaterializedInternal<K, V, ?>
• ProcessorParameters<K, V, ?, ?>
• isGlobalKTable flag

TableSourceNode is created when:

• TableSourceNodeBuilder is requested to build a TableSourceNode

isGlobalKTable Flag¶

TableSourceNode is given a isGlobalKTable flag when created.

The flag is used when writeToTopology (to add a global state store).

writeToTopology¶

void writeToTopology(
  InternalTopologyBuilder topologyBuilder)

writeToTopology...FIXME

writeToTopology is part of the GraphNode abstraction.