public class Joined<K,V,VO> extends Object
Joined
class represents optional params that can be passed to
KStream#join(KTable,...)
and
KStream#leftJoin(KTable,...)
operations.Modifier and Type | Method and Description |
---|---|
static <K,V,VO> Joined<K,V,VO> |
as(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. |
Duration |
gracePeriod() |
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 . |
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,
String name)
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,
String name,
Duration gracePeriod)
Create an instance of
Joined with key, value, and otherValue Serde instances. |
Joined<K,V,VO> |
withGracePeriod(Duration gracePeriod)
Set the grace period on the stream side of the join.
|
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(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. |
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)
Joined
with key, value, and otherValue Serde
instances.
null
values are accepted and will be replaced by the default serdes as defined in config.K
- key typeV
- value typeVO
- other value typekeySerde
- the key serde to use. If null
the default key serde from config will be usedvalueSerde
- the value serde to use. If null
the default value serde from config will be usedotherValueSerde
- the otherValue serde to use. If null
the default value serde from config will be usedJoined
instance with the provided serdespublic 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, String name)
Joined
with key, value, and otherValue Serde
instances.
null
values are accepted and will be replaced by the default serdes as defined in
config.K
- key typeV
- value typeVO
- other value typekeySerde
- the key serde to use. If null
the default key serde from config will be
usedvalueSerde
- the value serde to use. If null
the default value serde from config
will be usedotherValueSerde
- the otherValue serde to use. If null
the default value serde
from config will be usedname
- the name used as the base for naming components of the join including any
repartition topicsJoined
instance with the provided serdespublic 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, String name, Duration gracePeriod)
Joined
with key, value, and otherValue Serde
instances.
null
values are accepted and will be replaced by the default serdes as defined in
config.K
- key typeV
- value typeVO
- other value typekeySerde
- the key serde to use. If null
the default key serde from config will be
usedvalueSerde
- the value serde to use. If null
the default value serde from config
will be usedotherValueSerde
- the otherValue serde to use. If null
the default value serde
from config will be usedname
- the name used as the base for naming components of the join including any
repartition topicsgracePeriod
- stream buffer timeJoined
instance with the provided serdespublic static <K,V,VO> Joined<K,V,VO> keySerde(org.apache.kafka.common.serialization.Serde<K> keySerde)
Joined
with a key Serde
.
null
values are accepted and will be replaced by the default key serde as defined in config.K
- key typeV
- value typeVO
- other value typekeySerde
- the key serde to use. If null
the default key serde from config will be usedJoined
instance configured with the keySerdepublic static <K,V,VO> Joined<K,V,VO> valueSerde(org.apache.kafka.common.serialization.Serde<V> valueSerde)
Joined
with a value Serde
.
null
values are accepted and will be replaced by the default value serde as defined in config.K
- key typeV
- value typeVO
- other value typevalueSerde
- the value serde to use. If null
the default value serde from config will be usedJoined
instance configured with the valueSerdepublic static <K,V,VO> Joined<K,V,VO> otherValueSerde(org.apache.kafka.common.serialization.Serde<VO> otherValueSerde)
Joined
with an other value Serde
.
null
values are accepted and will be replaced by the default value serde as defined in config.K
- key typeV
- value typeVO
- other value typeotherValueSerde
- the otherValue serde to use. If null
the default value serde from config will be usedJoined
instance configured with the otherValueSerdepublic static <K,V,VO> Joined<K,V,VO> as(String name)
Joined
with base name for all components of the join, this may
include any repartition topics created to complete the join.K
- key typeV
- value typeVO
- other value typename
- the name used as the base for naming components of the join including any
repartition topicsJoined
instance configured with the namepublic Joined<K,V,VO> withKeySerde(org.apache.kafka.common.serialization.Serde<K> keySerde)
Serde
to be used. Null values are accepted and will be replaced by the default
key serde as defined in configkeySerde
- the key serde to use. If null the default key serde from config will be usedJoined
instance configured with the name
public Joined<K,V,VO> withValueSerde(org.apache.kafka.common.serialization.Serde<V> valueSerde)
Serde
to be used. Null values are accepted and will be replaced by the default
value serde as defined in configvalueSerde
- the value serde to use. If null the default value serde from config will be usedJoined
instance configured with the valueSerde
public Joined<K,V,VO> withOtherValueSerde(org.apache.kafka.common.serialization.Serde<VO> otherValueSerde)
Serde
to be used. Null values are accepted and will be replaced by the default
value serde as defined in configotherValueSerde
- the otherValue serde to use. If null the default value serde from config will be usedJoined
instance configured with the valueSerde
public Joined<K,V,VO> withName(String name)
name
- the name used as the base for naming components of the join including any
repartition topicsJoined
instance configured with the name
public Joined<K,V,VO> withGracePeriod(Duration gracePeriod)
gracePeriod
- the duration of the grace period. Must be less than the joining table's history retention.Joined
instance configured with the gracePeriodpublic Duration gracePeriod()
public org.apache.kafka.common.serialization.Serde<K> keySerde()
public org.apache.kafka.common.serialization.Serde<V> valueSerde()
public org.apache.kafka.common.serialization.Serde<VO> otherValueSerde()