KTableKTableJoinNode

KTableKTableJoinNode is a concrete StreamsGraphNode (as a BaseJoinProcessorNode) that is created (using KTableKTableJoinNodeBuilder.build method) for KTableImpl.join, KTableImpl.leftJoin and KTableImpl.outerJoin operators.

In other words, KTableKTableJoinNode represents KTableImpl.join, KTableImpl.leftJoin and KTableImpl.outerJoin operators.

Creating KTableKTableJoinNode Instance

KTableKTableJoinNode takes the following to be created:

  • Node name

  • ProcessorParameters<K, Change<V1>> of this join side

  • ProcessorParameters<K, Change<V2>> of the other join side

  • ProcessorParameters<K, Change<VR>> of the join merger

  • Name of this join side

  • Name of the other join side

  • Key Serde (Serde<K>)

  • Value Serde (Serde<VR>)

  • Names of the state stores of this join side

  • Names of the state stores of the other join side

  • StoreBuilder of TimestampedKeyValueStore (StoreBuilder<TimestampedKeyValueStore<K, VR>>)

writeToTopology Method

void writeToTopology(
  InternalTopologyBuilder topologyBuilder)
Note
 writeToTopology is part of the StreamsGraphNode Contract to…​FIXME.

writeToTopology…​FIXME

Creating KTableKTableJoinNode — build Method

KTableKTableJoinNode<K, V1, V2, VR> build()

build…​FIXME

Note
 build is used exclusively when KTableImpl is requested to doJoin (for KTableImpl.join, KTableImpl.leftJoin and KTableImpl.outerJoin operators).

results matching ""

    No results matching ""