Skip to content


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).


void writeToTopology(
  InternalTopologyBuilder topologyBuilder)


writeToTopology is part of the GraphNode abstraction.

Back to top