Package com.bakdata.kafka.streams.kstream

Class JoinedX<K,V1,V2>

java.lang.Object
com.bakdata.kafka.streams.kstream.JoinedX<K,V1,V2>
Type Parameters:
K - type of keys
V1 - this value type
V2 - other value type
public final class JoinedX<K,V1,V2> extends Object
Use Preconfigured to lazily configure Serde for Joined using Configurator
See Also:
  • Joined

  • Method Summary

    Modifier and Type
    Method
    Description
    static <K, V1, V2> JoinedX<K,V1,V2>
    as(String name)
     
    static <K, V1, V2> JoinedX<K,V1,V2>
    keySerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<K>> keySerde)
     
    static <K, V1, V2> JoinedX<K,V1,V2>
    keySerde(org.apache.kafka.common.serialization.Serde<K> keySerde)
     
    protected final JoinedX<K,V1,V2>
    modify(BiFunction<? super org.apache.kafka.streams.kstream.Joined<K,V1,V2>,? super com.bakdata.kafka.Configurator,? extends org.apache.kafka.streams.kstream.Joined<K,V1,V2>> modifier)
     
    protected final JoinedX<K,V1,V2>
    modify(Function<? super org.apache.kafka.streams.kstream.Joined<K,V1,V2>,? extends org.apache.kafka.streams.kstream.Joined<K,V1,V2>> modifier)
     
    protected JoinedX<K,V1,V2>
    newInstance(Function<com.bakdata.kafka.Configurator,org.apache.kafka.streams.kstream.Joined<K,V1,V2>> initializer)
     
    static <K, V1, V2> JoinedX<K,V1,V2>
    otherValueSerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V2>> otherValueSerde)
     
    static <K, V1, V2> JoinedX<K,V1,V2>
    otherValueSerde(org.apache.kafka.common.serialization.Serde<V2> otherValueSerde)
     
    static <K, V1, V2> JoinedX<K,V1,V2>
    valueSerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V1>> valueSerde)
     
    static <K, V1, V2> JoinedX<K,V1,V2>
    valueSerde(org.apache.kafka.common.serialization.Serde<V1> valueSerde)
     
    static <K, V1, V2> JoinedX<K,V1,V2>
    with(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<K>> keySerde, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V1>> valueSerde, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V2>> otherValueSerde)
     
    static <K, V1, V2> JoinedX<K,V1,V2>
    with(org.apache.kafka.common.serialization.Serde<K> keySerde, org.apache.kafka.common.serialization.Serde<V1> valueSerde, org.apache.kafka.common.serialization.Serde<V2> otherValueSerde)
     
    JoinedX<K,V1,V2>
    withGracePeriod(Duration gracePeriod)
     
    JoinedX<K,V1,V2>
    withKeySerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<K>> keySerde)
     
    JoinedX<K,V1,V2>
    withKeySerde(org.apache.kafka.common.serialization.Serde<K> keySerde)
     
    JoinedX<K,V1,V2>
    withName(String name)
     
    JoinedX<K,V1,V2>
    withOtherValueSerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V2>> otherValueSerde)
     
    JoinedX<K,V1,V2>
    withOtherValueSerde(org.apache.kafka.common.serialization.Serde<V2> otherValueSerde)
     
    JoinedX<K,V1,V2>
    withValueSerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V1>> valueSerde)
     
    JoinedX<K,V1,V2>
    withValueSerde(org.apache.kafka.common.serialization.Serde<V1> valueSerde)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Method Details

    • keySerde

      public static <K, V1, V2> JoinedX<K,V1,V2> keySerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<K>> keySerde)
      See Also:
      • Joined.keySerde(Serde)

    • keySerde

      public static <K, V1, V2> JoinedX<K,V1,V2> keySerde(org.apache.kafka.common.serialization.Serde<K> keySerde)
      See Also:
      • Joined.keySerde(Serde)

    • valueSerde

      public static <K, V1, V2> JoinedX<K,V1,V2> valueSerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V1>> valueSerde)
      See Also:
      • Joined.valueSerde(Serde)

    • valueSerde

      public static <K, V1, V2> JoinedX<K,V1,V2> valueSerde(org.apache.kafka.common.serialization.Serde<V1> valueSerde)
      See Also:
      • Joined.valueSerde(Serde)

    • otherValueSerde

      public static <K, V1, V2> JoinedX<K,V1,V2> otherValueSerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V2>> otherValueSerde)
      See Also:
      • Joined.otherValueSerde(Serde)

    • otherValueSerde

      public static <K, V1, V2> JoinedX<K,V1,V2> otherValueSerde(org.apache.kafka.common.serialization.Serde<V2> otherValueSerde)
      See Also:
      • Joined.otherValueSerde(Serde)

    • with

      public static <K, V1, V2> JoinedX<K,V1,V2> with(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<K>> keySerde, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V1>> valueSerde, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V2>> otherValueSerde)
      See Also:
      • Joined.with(Serde, Serde, Serde)

    • with

      public static <K, V1, V2> JoinedX<K,V1,V2> with(org.apache.kafka.common.serialization.Serde<K> keySerde, org.apache.kafka.common.serialization.Serde<V1> valueSerde, org.apache.kafka.common.serialization.Serde<V2> otherValueSerde)
      See Also:
      • Joined.with(Serde, Serde, Serde)

    • as

      public static <K, V1, V2> JoinedX<K,V1,V2> as(String name)
      See Also:
      • Joined.as(String)

    • withKeySerde

      public JoinedX<K,V1,V2> withKeySerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<K>> keySerde)
      See Also:
      • Joined.withKeySerde(Serde)

    • withKeySerde

      public JoinedX<K,V1,V2> withKeySerde(org.apache.kafka.common.serialization.Serde<K> keySerde)
      See Also:
      • Joined.withKeySerde(Serde)

    • withValueSerde

      public JoinedX<K,V1,V2> withValueSerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V1>> valueSerde)
      See Also:
      • Joined.withValueSerde(Serde)

    • withValueSerde

      public JoinedX<K,V1,V2> withValueSerde(org.apache.kafka.common.serialization.Serde<V1> valueSerde)
      See Also:
      • Joined.withValueSerde(Serde)

    • withOtherValueSerde

      public JoinedX<K,V1,V2> withOtherValueSerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V2>> otherValueSerde)
      See Also:
      • Joined.withOtherValueSerde(Serde)

    • withOtherValueSerde

      public JoinedX<K,V1,V2> withOtherValueSerde(org.apache.kafka.common.serialization.Serde<V2> otherValueSerde)
      See Also:
      • Joined.withOtherValueSerde(Serde)

    • withName

      public JoinedX<K,V1,V2> withName(String name)
      See Also:
      • Joined.withName(String)

    • withGracePeriod

      public JoinedX<K,V1,V2> withGracePeriod(Duration gracePeriod)
      See Also:
      • Joined.withGracePeriod(Duration)

    • newInstance

      protected JoinedX<K,V1,V2> newInstance(Function<com.bakdata.kafka.Configurator,org.apache.kafka.streams.kstream.Joined<K,V1,V2>> initializer)

    • modify

      protected final JoinedX<K,V1,V2> modify(BiFunction<? super org.apache.kafka.streams.kstream.Joined<K,V1,V2>,? super com.bakdata.kafka.Configurator,? extends org.apache.kafka.streams.kstream.Joined<K,V1,V2>> modifier)

    • modify

      protected final JoinedX<K,V1,V2> modify(Function<? super org.apache.kafka.streams.kstream.Joined<K,V1,V2>,? extends org.apache.kafka.streams.kstream.Joined<K,V1,V2>> modifier)