Package org.apache.kafka.streams.kstream
Class Joined<K,V,VO>
- java.lang.Object
-
- org.apache.kafka.streams.kstream.Joined<K,V,VO>
-
public class Joined<K,V,VO> extends java.lang.Object
TheJoined
class represents optional params that can be passed toKStream.join(org.apache.kafka.streams.kstream.KStream<K, VO>, org.apache.kafka.streams.kstream.ValueJoiner<? super V, ? super VO, ? extends VR>, org.apache.kafka.streams.kstream.JoinWindows)
,KStream.leftJoin(org.apache.kafka.streams.kstream.KStream<K, VO>, org.apache.kafka.streams.kstream.ValueJoiner<? super V, ? super VO, ? extends VR>, org.apache.kafka.streams.kstream.JoinWindows)
, andKStream.outerJoin(org.apache.kafka.streams.kstream.KStream<K, VO>, org.apache.kafka.streams.kstream.ValueJoiner<? super V, ? super VO, ? extends VR>, org.apache.kafka.streams.kstream.JoinWindows)
operations.
-
-
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 ofJoined
with a keySerde
.java.lang.String
name()
static <K,V,VO>
Joined<K,V,VO>named(java.lang.String name)
Create an instance ofJoined
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 ofJoined
with an other valueSerde
.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 ofJoined
with a valueSerde
.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 ofJoined
with key, value, and otherValueSerde
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 ofJoined
with key, value, and otherValueSerde
instances.Joined<K,V,VO>
withKeySerde(org.apache.kafka.common.serialization.Serde<K> keySerde)
Set the keySerde
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 otherValueSerde
to be used.Joined<K,V,VO>
withValueSerde(org.apache.kafka.common.serialization.Serde<V> valueSerde)
Set the valueSerde
to be used.
-
-
-
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 ofJoined
with key, value, and otherValueSerde
instances.null
values are accepted and will be replaced by the default serdes as defined in config.- Type Parameters:
K
- key typeV
- value typeVO
- other value type- Parameters:
keySerde
- the key serde to use. Ifnull
the default key serde from config will be usedvalueSerde
- the value serde to use. Ifnull
the default value serde from config will be usedotherValueSerde
- the otherValue serde to use. Ifnull
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 ofJoined
with key, value, and otherValueSerde
instances.null
values are accepted and will be replaced by the default serdes as defined in config.- Type Parameters:
K
- key typeV
- value typeVO
- other value type- Parameters:
keySerde
- the key serde to use. Ifnull
the default key serde from config will be usedvalueSerde
- the value serde to use. Ifnull
the default value serde from config will be usedotherValueSerde
- the otherValue serde to use. Ifnull
the default value serde from config will be usedname
- 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 ofJoined
with a keySerde
.null
values are accepted and will be replaced by the default key serde as defined in config.- Type Parameters:
K
- key typeV
- value typeVO
- other value type- Parameters:
keySerde
- the key serde to use. Ifnull
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 ofJoined
with a valueSerde
.null
values are accepted and will be replaced by the default value serde as defined in config.- Type Parameters:
K
- key typeV
- value typeVO
- other value type- Parameters:
valueSerde
- the value serde to use. Ifnull
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 ofJoined
with an other valueSerde
.null
values are accepted and will be replaced by the default value serde as defined in config.- Type Parameters:
K
- key typeV
- value typeVO
- other value type- Parameters:
otherValueSerde
- the otherValue serde to use. Ifnull
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 ofJoined
with base name for all components of the join, this may include any repartition topics created to complete the join.- Type Parameters:
K
- key typeV
- value typeVO
- 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 keySerde
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 thename
-
withValueSerde
public Joined<K,V,VO> withValueSerde(org.apache.kafka.common.serialization.Serde<V> valueSerde)
Set the valueSerde
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 thevalueSerde
-
withOtherValueSerde
public Joined<K,V,VO> withOtherValueSerde(org.apache.kafka.common.serialization.Serde<VO> otherValueSerde)
Set the otherValueSerde
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 thevalueSerde
-
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 thename
-
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()
-
-