Class Joined<K,​V,​VO>

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.kafka.common.serialization.Serde<K> keySerde()  
      static <K,​V,​VO>
      Joined<K,​V,​VO>
      keySerde​(org.apache.kafka.common.serialization.Serde<K> keySerde)
      Create an instance of Joined with a key Serde.
      java.lang.String name()  
      static <K,​V,​VO>
      Joined<K,​V,​VO>
      named​(java.lang.String name)
      Create an instance of Joined with base name for all components of the join, this may include any repartition topics created to complete the join.
      org.apache.kafka.common.serialization.Serde<VO> otherValueSerde()  
      static <K,​V,​VO>
      Joined<K,​V,​VO>
      otherValueSerde​(org.apache.kafka.common.serialization.Serde<VO> otherValueSerde)
      Create an instance of Joined with an other value Serde.
      org.apache.kafka.common.serialization.Serde<V> valueSerde()  
      static <K,​V,​VO>
      Joined<K,​V,​VO>
      valueSerde​(org.apache.kafka.common.serialization.Serde<V> valueSerde)
      Create an instance of Joined with a value Serde.
      static <K,​V,​VO>
      Joined<K,​V,​VO>
      with​(org.apache.kafka.common.serialization.Serde<K> keySerde, org.apache.kafka.common.serialization.Serde<V> valueSerde, org.apache.kafka.common.serialization.Serde<VO> otherValueSerde)
      Create an instance of Joined with key, value, and otherValue Serde instances.
      static <K,​V,​VO>
      Joined<K,​V,​VO>
      with​(org.apache.kafka.common.serialization.Serde<K> keySerde, org.apache.kafka.common.serialization.Serde<V> valueSerde, org.apache.kafka.common.serialization.Serde<VO> otherValueSerde, java.lang.String name)
      Create an instance of Joined with key, value, and otherValue Serde instances.
      Joined<K,​V,​VO> withKeySerde​(org.apache.kafka.common.serialization.Serde<K> keySerde)
      Set the key Serde to be used.
      Joined<K,​V,​VO> withName​(java.lang.String name)
      Set the base name used for all components of the join, this may include any repartition topics created to complete the join.
      Joined<K,​V,​VO> withOtherValueSerde​(org.apache.kafka.common.serialization.Serde<VO> otherValueSerde)
      Set the otherValue Serde to be used.
      Joined<K,​V,​VO> withValueSerde​(org.apache.kafka.common.serialization.Serde<V> valueSerde)
      Set the value Serde to be used.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Method Detail

      • with

        public static <K,​V,​VO> Joined<K,​V,​VO> with​(org.apache.kafka.common.serialization.Serde<K> keySerde,
                                                                           org.apache.kafka.common.serialization.Serde<V> valueSerde,
                                                                           org.apache.kafka.common.serialization.Serde<VO> otherValueSerde)
        Create an instance of Joined with key, value, and otherValue Serde instances. null values are accepted and will be replaced by the default serdes as defined in config.
        Type Parameters:
        K - key type
        V - value type
        VO - other value type
        Parameters:
        keySerde - the key serde to use. If null the default key serde from config will be used
        valueSerde - the value serde to use. If null the default value serde from config will be used
        otherValueSerde - the otherValue serde to use. If null the default value serde from config will be used
        Returns:
        new Joined instance with the provided serdes
      • with

        public static <K,​V,​VO> Joined<K,​V,​VO> with​(org.apache.kafka.common.serialization.Serde<K> keySerde,
                                                                           org.apache.kafka.common.serialization.Serde<V> valueSerde,
                                                                           org.apache.kafka.common.serialization.Serde<VO> otherValueSerde,
                                                                           java.lang.String name)
        Create an instance of Joined with key, value, and otherValue Serde instances. null values are accepted and will be replaced by the default serdes as defined in config.
        Type Parameters:
        K - key type
        V - value type
        VO - other value type
        Parameters:
        keySerde - the key serde to use. If null the default key serde from config will be used
        valueSerde - the value serde to use. If null the default value serde from config will be used
        otherValueSerde - the otherValue serde to use. If null the default value serde from config will be used
        name - the name used as the base for naming components of the join including any repartition topics
        Returns:
        new Joined instance with the provided serdes
      • keySerde

        public static <K,​V,​VO> Joined<K,​V,​VO> keySerde​(org.apache.kafka.common.serialization.Serde<K> keySerde)
        Create an instance of Joined with a key Serde. null values are accepted and will be replaced by the default key serde as defined in config.
        Type Parameters:
        K - key type
        V - value type
        VO - other value type
        Parameters:
        keySerde - the key serde to use. If null the default key serde from config will be used
        Returns:
        new Joined instance configured with the keySerde
      • valueSerde

        public static <K,​V,​VO> Joined<K,​V,​VO> valueSerde​(org.apache.kafka.common.serialization.Serde<V> valueSerde)
        Create an instance of Joined with a value Serde. null values are accepted and will be replaced by the default value serde as defined in config.
        Type Parameters:
        K - key type
        V - value type
        VO - other value type
        Parameters:
        valueSerde - the value serde to use. If null the default value serde from config will be used
        Returns:
        new Joined instance configured with the valueSerde
      • otherValueSerde

        public static <K,​V,​VO> Joined<K,​V,​VO> otherValueSerde​(org.apache.kafka.common.serialization.Serde<VO> otherValueSerde)
        Create an instance of Joined with an other value Serde. null values are accepted and will be replaced by the default value serde as defined in config.
        Type Parameters:
        K - key type
        V - value type
        VO - other value type
        Parameters:
        otherValueSerde - the otherValue serde to use. If null the default value serde from config will be used
        Returns:
        new Joined instance configured with the otherValueSerde
      • named

        public static <K,​V,​VO> Joined<K,​V,​VO> named​(java.lang.String name)
        Create an instance of Joined with base name for all components of the join, this may include any repartition topics created to complete the join.
        Type Parameters:
        K - key type
        V - value type
        VO - other value type
        Parameters:
        name - the name used as the base for naming components of the join including any repartition topics
        Returns:
        new Joined instance configured with the name
      • withKeySerde

        public Joined<K,​V,​VO> withKeySerde​(org.apache.kafka.common.serialization.Serde<K> keySerde)
        Set the key Serde to be used. Null values are accepted and will be replaced by the default key serde as defined in config
        Parameters:
        keySerde - the key serde to use. If null the default key serde from config will be used
        Returns:
        new Joined instance configured with the name
      • withValueSerde

        public Joined<K,​V,​VO> withValueSerde​(org.apache.kafka.common.serialization.Serde<V> valueSerde)
        Set the value Serde to be used. Null values are accepted and will be replaced by the default value serde as defined in config
        Parameters:
        valueSerde - the value serde to use. If null the default value serde from config will be used
        Returns:
        new Joined instance configured with the valueSerde
      • withOtherValueSerde

        public Joined<K,​V,​VO> withOtherValueSerde​(org.apache.kafka.common.serialization.Serde<VO> otherValueSerde)
        Set the otherValue Serde to be used. Null values are accepted and will be replaced by the default value serde as defined in config
        Parameters:
        otherValueSerde - the otherValue serde to use. If null the default value serde from config will be used
        Returns:
        new Joined instance configured with the valueSerde
      • withName

        public Joined<K,​V,​VO> withName​(java.lang.String name)
        Set the base name used for all components of the join, this may include any repartition topics created to complete the join.
        Parameters:
        name - the name used as the base for naming components of the join including any repartition topics
        Returns:
        new Joined instance configured with the name
      • keySerde

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

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

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

        public java.lang.String name()