org.apache.kafka.streams.kstream

Class StreamJoined<K,V1,V2>

java.lang.Object

org.apache.kafka.streams.kstream.StreamJoined<K,V1,V2>

Type Parameters:

K - the key type

V1 - this value type

V2 - other value type

public class StreamJoined<K,V1,V2>
extends Object

Class used to configure the name of the join processor, the repartition topic name, state stores or state store names in Stream-Stream join.

Field Summary

Fields

Modifier and Type	Field and Description
protected Serde<K>	keySerde
protected String	name
protected WindowBytesStoreSupplier	otherStoreSupplier
protected Serde<V2>	otherValueSerde
protected String	storeName
protected WindowBytesStoreSupplier	thisStoreSupplier
protected Serde<V1>	valueSerde

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	StreamJoined(StreamJoined<K,V1,V2> streamJoined)

Method Summary

Modifier and Type	Method and Description
static <K,V1,V2> StreamJoined<K,V1,V2>	as(String storeName) Creates a StreamJoined instance using the provided name for the state stores and hence the changelog topics for the join stores.
String	toString()
static <K,V1,V2> StreamJoined<K,V1,V2>	with(Serde<K> keySerde, Serde<V1> valueSerde, Serde<V2> otherValueSerde) Creates a StreamJoined instance with the provided serdes to configure the stores for the join.
static <K,V1,V2> StreamJoined<K,V1,V2>	with(WindowBytesStoreSupplier storeSupplier, WindowBytesStoreSupplier otherStoreSupplier) Creates a StreamJoined instance with the provided store suppliers.
StreamJoined<K,V1,V2>	withKeySerde(Serde<K> keySerde) Configure with the provided Serde for the key
StreamJoined<K,V1,V2>	withName(String name) Set the name to use for the join processor and the repartition topic(s) if required.
StreamJoined<K,V1,V2>	withOtherStoreSupplier(WindowBytesStoreSupplier otherStoreSupplier) Configure with the provided WindowBytesStoreSupplier for the other store supplier.
StreamJoined<K,V1,V2>	withOtherValueSerde(Serde<V2> otherValueSerde) Configure with the provided Serde for the other value
StreamJoined<K,V1,V2>	withStoreName(String storeName) Sets the base store name to use for both sides of the join.
StreamJoined<K,V1,V2>	withThisStoreSupplier(WindowBytesStoreSupplier thisStoreSupplier) Configure with the provided WindowBytesStoreSupplier for this store supplier.
StreamJoined<K,V1,V2>	withValueSerde(Serde<V1> valueSerde) Configure with the provided Serde for this value

Methods inherited from class java.lang.Object

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

Field Detail

keySerde

protected final Serde<K> keySerde

valueSerde

protected final Serde<V1> valueSerde

otherValueSerde

protected final Serde<V2> otherValueSerde

thisStoreSupplier

protected final WindowBytesStoreSupplier thisStoreSupplier

otherStoreSupplier

protected final WindowBytesStoreSupplier otherStoreSupplier

name

protected final String name

storeName

protected final String storeName

Constructor Detail

StreamJoined

protected StreamJoined(StreamJoined<K,V1,V2> streamJoined)

Method Detail

with

public static <K,V1,V2> StreamJoined<K,V1,V2> with(WindowBytesStoreSupplier storeSupplier,
                                                   WindowBytesStoreSupplier otherStoreSupplier)

Creates a StreamJoined instance with the provided store suppliers. The store suppliers must implement the WindowBytesStoreSupplier interface. The store suppliers must provide unique names or a StreamsException is thrown.

Type Parameters:

K - the key type

V1 - this value type

V2 - other value type

Parameters:

storeSupplier - this store supplier

otherStoreSupplier - other store supplier

Returns:

StreamJoined instance

as

public static <K,V1,V2> StreamJoined<K,V1,V2> as(String storeName)

Creates a StreamJoined instance using the provided name for the state stores and hence the changelog topics for the join stores. The name for the stores will be ${applicationId}-<storeName>-this-join and ${applicationId}-<storeName>-other-join or ${applicationId}-<storeName>-outer-this-join and ${applicationId}-<storeName>-outer-other-join depending if the join is an inner-join or an outer join. The changelog topics will have the -changelog suffix. The user should note that even though the join stores will have a specified name, the stores will remain unavailable for querying.

Type Parameters:

K - The key type

V1 - This value type

V2 - Other value type

Parameters:

storeName - The name to use for the store

Returns:

StreamJoined instance

with

public static <K,V1,V2> StreamJoined<K,V1,V2> with(Serde<K> keySerde,
                                                   Serde<V1> valueSerde,
                                                   Serde<V2> otherValueSerde)

Creates a StreamJoined instance with the provided serdes to configure the stores for the join.

Type Parameters:

K - The key type

V1 - This value type

V2 - Other value type

Parameters:

keySerde - The key serde

valueSerde - This value serde

otherValueSerde - Other value serde

Returns:

StreamJoined instance

withName

public StreamJoined<K,V1,V2> withName(String name)

Set the name to use for the join processor and the repartition topic(s) if required.

Parameters:

name - the name to use

Returns:

a new StreamJoined instance

withStoreName

public StreamJoined<K,V1,V2> withStoreName(String storeName)

Sets the base store name to use for both sides of the join. The name for the state stores and hence the changelog topics for the join stores. The name for the stores will be ${applicationId}-<storeName>-this-join and ${applicationId}-<storeName>-other-join or ${applicationId}-<storeName>-outer-this-join and ${applicationId}-<storeName>-outer-other-join depending if the join is an inner-join or an outer join. The changelog topics will have the -changelog suffix. The user should note that even though the join stores will have a specified name, the stores will remain unavailable for querying.

Parameters:

storeName - the storeName to use

Returns:

withKeySerde

public StreamJoined<K,V1,V2> withKeySerde(Serde<K> keySerde)

Configure with the provided Serde for the key

Parameters:

keySerde - the serde to use for the key

Returns:

a new StreamJoined configured with the keySerde

withValueSerde

public StreamJoined<K,V1,V2> withValueSerde(Serde<V1> valueSerde)

Configure with the provided Serde for this value

Parameters:

valueSerde - the serde to use for this value (calling or left side of the join)

Returns:

a new StreamJoined configured with the valueSerde

withOtherValueSerde

public StreamJoined<K,V1,V2> withOtherValueSerde(Serde<V2> otherValueSerde)

Configure with the provided Serde for the other value

Parameters:

otherValueSerde - the serde to use for the other value (other or right side of the join)

Returns:

a new StreamJoined configured with the otherValueSerde

withThisStoreSupplier

public StreamJoined<K,V1,V2> withThisStoreSupplier(WindowBytesStoreSupplier thisStoreSupplier)

Configure with the provided WindowBytesStoreSupplier for this store supplier. Please note this method only provides the store supplier for the left side of the join. If you wish to also provide a store supplier for the right (i.e., other) side you must use the withOtherStoreSupplier(WindowBytesStoreSupplier) method

Parameters:

thisStoreSupplier - the store supplier to use for this store supplier (calling or left side of the join)

Returns:

a new StreamJoined configured with thisStoreSupplier

withOtherStoreSupplier

public StreamJoined<K,V1,V2> withOtherStoreSupplier(WindowBytesStoreSupplier otherStoreSupplier)

Configure with the provided WindowBytesStoreSupplier for the other store supplier. Please note this method only provides the store supplier for the right side of the join. If you wish to also provide a store supplier for the left side you must use the withThisStoreSupplier(WindowBytesStoreSupplier) method

Parameters:

otherStoreSupplier - the store supplier to use for the other store supplier (other or right side of the join)

Returns:

a new StreamJoined configured with otherStoreSupplier

toString

public String toString()

Overrides:

toString in class Object