Class KTableKTableJoinNode<K,​V1,​V2,​VR>


  • public class KTableKTableJoinNode<K,​V1,​V2,​VR>
    extends StreamsGraphNode
    Too much specific information to generalize so the KTable-KTable join requires a specific node.
    • Method Detail

      • keySerde

        public org.apache.kafka.common.serialization.Serde<K> keySerde()
      • valueSerde

        public org.apache.kafka.common.serialization.Serde<VR> valueSerde()
      • joinThisStoreNames

        public java.lang.String[] joinThisStoreNames()
      • joinOtherStoreNames

        public java.lang.String[] joinOtherStoreNames()
      • queryableStoreName

        public java.lang.String queryableStoreName()
      • joinMerger

        public KTableKTableJoinMerger<K,​VR> joinMerger()
        The supplier which provides processor with KTable-KTable join merge functionality.
      • toString

        public java.lang.String toString()