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

results matching ""

    No results matching ""