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)
writeToTopology is part of the StreamsGraphNode Contract to…​FIXME.


results matching ""

    No results matching ""