kafka-streams-internals-StreamTableJoinNode.adoc

StreamTableJoinNode

StreamTableJoinNode is a concrete StreamsGraphNode that represents (and is created for) KStreamImpl.join and KStreamImpl.leftJoin operators.

Creating StreamTableJoinNode Instance

StreamTableJoinNode takes the following to be created:

• Node name

• ProcessorParameters<K, V>

• Names of the state stores

• Node name of the other join side

writeToTopology Method

void writeToTopology(
  InternalTopologyBuilder topologyBuilder)

Note	writeToTopology is part of the StreamsGraphNode Contract to…​FIXME.

writeToTopology…​FIXME