java.lang.Object

com.bakdata.kafka.streams.kstream.StreamJoinedX<K,V1,V2>

Type Parameters:: K - type of keys; V1 - this value type; V2 - other value type

public final class StreamJoinedX<K,V1,V2> extends Object

Use Preconfigured to lazily configure Serde for StreamJoined using Configurator

See Also:

StreamJoined

Method Summary

Modifier and Type

Method

Description

static <K, V1, V2> StreamJoinedX<K,V1,V2>

as(String storeName)

static <K, V1, V2> StreamJoinedX<K,V1,V2>

keySerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<K>> keySerde)

Create an instance of StreamJoinedX with provided key serde

static <K, V1, V2> StreamJoinedX<K,V1,V2>

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

Create an instance of StreamJoinedX with provided key serde

protected final StreamJoinedX<K,V1,V2>

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

protected final StreamJoinedX<K,V1,V2>

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

protected StreamJoinedX<K,V1,V2>

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

static <K, V1, V2> StreamJoinedX<K,V1,V2>

otherValueSerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V2>> otherValueSerde)

Create an instance of StreamJoinedX with provided other value serde

static <K, V1, V2> StreamJoinedX<K,V1,V2>

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

Create an instance of StreamJoinedX with provided other value serde

static <K, V1, V2> StreamJoinedX<K,V1,V2>

valueSerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V1>> valueSerde)

Create an instance of StreamJoinedX with provided value serde

static <K, V1, V2> StreamJoinedX<K,V1,V2>

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

Create an instance of StreamJoinedX with provided value serde

static <K, V1, V2> StreamJoinedX<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> StreamJoinedX<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)

static <K, V1, V2> StreamJoinedX<K,V1,V2>

with(org.apache.kafka.streams.state.DslStoreSuppliers storeSuppliers)

static <K, V1, V2> StreamJoinedX<K,V1,V2>

with(org.apache.kafka.streams.state.WindowBytesStoreSupplier storeSupplier, org.apache.kafka.streams.state.WindowBytesStoreSupplier otherStoreSupplier)

StreamJoinedX<K,V1,V2>

withDslStoreSuppliers(org.apache.kafka.streams.state.DslStoreSuppliers dslStoreSuppliers)

StreamJoinedX<K,V1,V2>

withKeySerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<K>> keySerde)

StreamJoinedX<K,V1,V2>

withKeySerde(org.apache.kafka.common.serialization.Serde<K> keySerde)

StreamJoinedX<K,V1,V2>

withLoggingDisabled()

StreamJoinedX<K,V1,V2>

withLoggingEnabled(Map<String,String> config)

StreamJoinedX<K,V1,V2>

withName(String name)

StreamJoinedX<K,V1,V2>

withOtherStoreSupplier(org.apache.kafka.streams.state.WindowBytesStoreSupplier otherStoreSupplier)

StreamJoinedX<K,V1,V2>

withOtherValueSerde(com.bakdata.kafka.Preconfigured<org.apache.kafka.common.serialization.Serde<V2>> otherValueSerde)

StreamJoinedX<K,V1,V2>

withOtherValueSerde(org.apache.kafka.common.serialization.Serde<V2> otherValueSerde)

StreamJoinedX<K,V1,V2>

withStoreName(String storeName)

StreamJoinedX<K,V1,V2>

withThisStoreSupplier(org.apache.kafka.streams.state.WindowBytesStoreSupplier thisStoreSupplier)

StreamJoinedX<K,V1,V2>

withValueSerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V1>> valueSerde)

StreamJoinedX<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> StreamJoinedX<K,V1,V2> keySerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<K>> keySerde)
  
  Create an instance of StreamJoinedX with provided key serde
  
  Type Parameters:
  
  K - type of keys
  
  V1 - this value type
  
  V2 - other value type
  
  Parameters:
  
  keySerde - Serde to use for keys
  
  Returns:
  
  a new instance of StreamJoinedX
- keySerde
  
  public static <K, V1, V2> StreamJoinedX<K,V1,V2> keySerde(org.apache.kafka.common.serialization.Serde<K> keySerde)
  
  Create an instance of StreamJoinedX with provided key serde
  
  Type Parameters:
  
  K - type of keys
  
  V1 - this value type
  
  V2 - other value type
  
  Parameters:
  
  keySerde - Serde to use for keys
  
  Returns:
  
  a new instance of StreamJoinedX
- valueSerde
  
  public static <K, V1, V2> StreamJoinedX<K,V1,V2> valueSerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V1>> valueSerde)
  
  Create an instance of StreamJoinedX with provided value serde
  
  Type Parameters:
  
  K - type of keys
  
  V1 - this value type
  
  V2 - other value type
  
  Parameters:
  
  valueSerde - Serde to use for values
  
  Returns:
  
  a new instance of StreamJoinedX
- valueSerde
  
  public static <K, V1, V2> StreamJoinedX<K,V1,V2> valueSerde(org.apache.kafka.common.serialization.Serde<V1> valueSerde)
  
  Create an instance of StreamJoinedX with provided value serde
  
  Type Parameters:
  
  K - type of keys
  
  V1 - this value type
  
  V2 - other value type
  
  Parameters:
  
  valueSerde - Serde to use for values
  
  Returns:
  
  a new instance of StreamJoinedX
- otherValueSerde
  
  public static <K, V1, V2> StreamJoinedX<K,V1,V2> otherValueSerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V2>> otherValueSerde)
  
  Create an instance of StreamJoinedX with provided other value serde
  
  Type Parameters:
  
  K - type of keys
  
  V1 - this value type
  
  V2 - other value type
  
  Parameters:
  
  otherValueSerde - Serde to use for other values
  
  Returns:
  
  a new instance of StreamJoinedX
- otherValueSerde
  
  public static <K, V1, V2> StreamJoinedX<K,V1,V2> otherValueSerde(org.apache.kafka.common.serialization.Serde<V2> otherValueSerde)
  
  Create an instance of StreamJoinedX with provided other value serde
  
  Type Parameters:
  
  K - type of keys
  
  V1 - this value type
  
  V2 - other value type
  
  Parameters:
  
  otherValueSerde - Serde to use for other values
  
  Returns:
  
  a new instance of StreamJoinedX
- with
  
  public static <K, V1, V2> StreamJoinedX<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:
  
  StreamJoined.with(Serde, Serde, Serde)
- with
  
  public static <K, V1, V2> StreamJoinedX<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:
  
  StreamJoined.with(Serde, Serde, Serde)
- as
  
  public static <K, V1, V2> StreamJoinedX<K,V1,V2> as(String storeName)
  See Also:
  
  StreamJoined.as(String)
- with
  
  public static <K, V1, V2> StreamJoinedX<K,V1,V2> with(org.apache.kafka.streams.state.DslStoreSuppliers storeSuppliers)
  See Also:
  
  StreamJoined.with(DslStoreSuppliers)
- with
  
  public static <K, V1, V2> StreamJoinedX<K,V1,V2> with(org.apache.kafka.streams.state.WindowBytesStoreSupplier storeSupplier, org.apache.kafka.streams.state.WindowBytesStoreSupplier otherStoreSupplier)
  See Also:
  
  StreamJoined.with(WindowBytesStoreSupplier, WindowBytesStoreSupplier)
- withKeySerde
  
  public StreamJoinedX<K,V1,V2> withKeySerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<K>> keySerde)
  See Also:
  
  StreamJoined.withKeySerde(Serde)
- withKeySerde
  
  public StreamJoinedX<K,V1,V2> withKeySerde(org.apache.kafka.common.serialization.Serde<K> keySerde)
  See Also:
  
  StreamJoined.withKeySerde(Serde)
- withValueSerde
  
  public StreamJoinedX<K,V1,V2> withValueSerde(com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V1>> valueSerde)
  See Also:
  
  StreamJoined.withValueSerde(Serde)
- withValueSerde
  
  public StreamJoinedX<K,V1,V2> withValueSerde(org.apache.kafka.common.serialization.Serde<V1> valueSerde)
  See Also:
  
  StreamJoined.withValueSerde(Serde)
- withOtherValueSerde
  
  public StreamJoinedX<K,V1,V2> withOtherValueSerde(com.bakdata.kafka.Preconfigured<org.apache.kafka.common.serialization.Serde<V2>> otherValueSerde)
  See Also:
  
  StreamJoined.withOtherValueSerde(Serde)
- withOtherValueSerde
  
  public StreamJoinedX<K,V1,V2> withOtherValueSerde(org.apache.kafka.common.serialization.Serde<V2> otherValueSerde)
  See Also:
  
  StreamJoined.withOtherValueSerde(Serde)
- withDslStoreSuppliers
  
  public StreamJoinedX<K,V1,V2> withDslStoreSuppliers(org.apache.kafka.streams.state.DslStoreSuppliers dslStoreSuppliers)
  See Also:
  
  StreamJoined.withDslStoreSuppliers(DslStoreSuppliers)
- withName
  
  public StreamJoinedX<K,V1,V2> withName(String name)
  See Also:
  
  StreamJoined.withName(String)
- withStoreName
  
  public StreamJoinedX<K,V1,V2> withStoreName(String storeName)
  See Also:
  
  StreamJoined.withStoreName(String)
- withLoggingEnabled
  
  public StreamJoinedX<K,V1,V2> withLoggingEnabled(Map<String,String> config)
  See Also:
  
  StreamJoined.withLoggingEnabled(Map)
- withLoggingDisabled
  
  public StreamJoinedX<K,V1,V2> withLoggingDisabled()
  See Also:
  
  StreamJoined.withLoggingDisabled()
- withThisStoreSupplier
  
  public StreamJoinedX<K,V1,V2> withThisStoreSupplier(org.apache.kafka.streams.state.WindowBytesStoreSupplier thisStoreSupplier)
  See Also:
  
  StreamJoined.withThisStoreSupplier(WindowBytesStoreSupplier)
- withOtherStoreSupplier
  
  public StreamJoinedX<K,V1,V2> withOtherStoreSupplier(org.apache.kafka.streams.state.WindowBytesStoreSupplier otherStoreSupplier)
  See Also:
  
  StreamJoined.withOtherStoreSupplier(WindowBytesStoreSupplier)
- newInstance
  
  protected StreamJoinedX<K,V1,V2> newInstance(Function<com.bakdata.kafka.Configurator,org.apache.kafka.streams.kstream.StreamJoined<K,V1,V2>> initializer)
- modify
  
  protected final StreamJoinedX<K,V1,V2> modify(BiFunction<? super org.apache.kafka.streams.kstream.StreamJoined<K,V1,V2>,? super com.bakdata.kafka.Configurator,? extends org.apache.kafka.streams.kstream.StreamJoined<K,V1,V2>> modifier)
- modify
  
  protected final StreamJoinedX<K,V1,V2> modify(Function<? super org.apache.kafka.streams.kstream.StreamJoined<K,V1,V2>,? extends org.apache.kafka.streams.kstream.StreamJoined<K,V1,V2>> modifier)

Class StreamJoinedX<K,V1,V2>

Method Summary

Methods inherited from class java.lang.Object

Method Details

keySerde

keySerde

valueSerde

valueSerde

otherValueSerde

otherValueSerde

with

with

as

with

with

withKeySerde

withKeySerde

withValueSerde

withValueSerde

withOtherValueSerde

withOtherValueSerde

withDslStoreSuppliers

withName

withStoreName

withLoggingEnabled

withLoggingDisabled

withThisStoreSupplier

withOtherStoreSupplier

newInstance

modify

modify