Class StreamJoinedInternal<K,​V1,​V2>


  • public class StreamJoinedInternal<K,​V1,​V2>
    extends StreamJoined<K,​V1,​V2>
    • Constructor Detail

      • StreamJoinedInternal

        public StreamJoinedInternal​(StreamJoined<K,​V1,​V2> streamJoined)
    • Method Detail

      • keySerde

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

        public org.apache.kafka.common.serialization.Serde<V1> valueSerde()
      • otherValueSerde

        public org.apache.kafka.common.serialization.Serde<V2> otherValueSerde()
      • name

        public java.lang.String name()
      • storeName

        public java.lang.String storeName()