StreamTableJoinNode

Author: jaceklaskowski

kafka-streams-internals-KStreamImpl.adoc

@@ -28,15 +28,15 @@
 
 [source, java]
 ----
-<V1, R> KStream<K, R> doStreamTableJoin(
-  final KTable<K, V1> other,
-  final ValueJoiner<? super V, ? super V1, ? extends R> joiner,
-  final boolean leftJoin)
+KStream<K, R> doStreamTableJoin(
+  KTable<K, V1> other,
+  ValueJoiner<? super V, ? super V1, ? extends R> joiner,
+  boolean leftJoin)
 ----
 
 `doStreamTableJoin`...FIXME
 
-NOTE: `doStreamTableJoin` is used when...FIXME
+NOTE: `doStreamTableJoin` is used when `KStreamImpl` is requested to <<join, join>> and <<leftJoin, leftJoin>>.
 
 === [[doJoin]] `doJoin` Internal Method
 
@@ -441,3 +441,24 @@ KStream<K, VR> doFlatTransformValues(
 `doFlatTransformValues`...FIXME
 
 NOTE: `doFlatTransformValues` is used exclusively when `KStreamImpl` is requested to <<flatTransformValues, flatTransformValues>>.
+
+=== [[globalTableJoin]] `globalTableJoin` Internal Method
+
+[source, java]
+----
+KStream<K, VR> globalTableJoin(
+  GlobalKTable<KG, VG> globalTable,
+  KeyValueMapper<
+    ? super K,
+    ? super V,
+    ? extends KG> keyMapper,
+  ValueJoiner<
+    ? super V,
+    ? super VG,
+    ? extends VR> joiner,
+  boolean leftJoin)
+----
+
+`globalTableJoin`...FIXME
+
+NOTE: `globalTableJoin` is used when `KStreamImpl` is requested to <<join, join>> and <<leftJoin, leftJoin>>.

kafka-streams-internals-StreamTableJoinNode.adoc

@@ -1,12 +1,22 @@
 == [[StreamTableJoinNode]] StreamTableJoinNode
 
-`StreamTableJoinNode` is...FIXME
+`StreamTableJoinNode` is a concrete <<kafka-streams-internals-StreamsGraphNode.adoc#, StreamsGraphNode>> that represents (and is <<creating-instance, created>> for) <<kafka-streams-internals-KStreamImpl.adoc#join, KStreamImpl.join>> and <<kafka-streams-internals-KStreamImpl.adoc#leftJoin, KStreamImpl.leftJoin>> operators.
+
+=== [[creating-instance]] Creating StreamTableJoinNode Instance
+
+`StreamTableJoinNode` takes the following to be created:
+
+* [[nodeName]] Node name
+* [[processorParameters]] `ProcessorParameters<K, V>`
+* [[storeNames]] Names of the state stores
+* [[otherJoinSideNodeName]] Node name of the other join side
 
 === [[writeToTopology]] `writeToTopology` Method
 
 [source, java]
 ----
-void writeToTopology(final InternalTopologyBuilder topologyBuilder)
+void writeToTopology(
+  InternalTopologyBuilder topologyBuilder)
 ----
 
 NOTE: `writeToTopology` is part of the <<kafka-streams-internals-StreamsGraphNode.adoc#writeToTopology, StreamsGraphNode Contract>> to...FIXME.

kafka-streams-internals-StreamsGraphNode.adoc

@@ -100,7 +100,7 @@ Base of <<kafka-streams-internals-GlobalStoreNode.adoc#, GlobalStoreNode>>
 Base of <<kafka-streams-internals-TableSourceNode.adoc#, TableSourceNode>>
 
 | <<kafka-streams-internals-StreamTableJoinNode.adoc#, StreamTableJoinNode>>
-| [[StreamTableJoinNode]]
+| [[StreamTableJoinNode]] Represents <<kafka-streams-internals-KStreamImpl.adoc#join, KStreamImpl.join>> and <<kafka-streams-internals-KStreamImpl.adoc#leftJoin, KStreamImpl.leftJoin>> operators
 
 | <<kafka-streams-internals-TableProcessorNode.adoc#, TableProcessorNode>>
 | [[TableProcessorNode]] Represents <<kafka-streams-internals-KTableImpl.adoc#filter, KTableImpl.filter>>, <<kafka-streams-internals-KTableImpl.adoc#filterNot, KTableImpl.filterNot>>, <<kafka-streams-internals-KTableImpl.adoc#mapValues, KTableImpl.mapValues>>, and <<kafka-streams-internals-KTableImpl.adoc#transformValues, KTableImpl.transformValues>> operators