org.apache.kafka.streams.kstream

Class TableJoined<K,KO>

java.lang.Object

org.apache.kafka.streams.kstream.TableJoined<K,KO>

Type Parameters:

K - this key type ; key type for the left (primary) table

KO - other key type ; key type for the right (foreign key) table

public class TableJoined<K,KO>
extends Object

The TableJoined class represents optional parameters that can be passed to KTable#join(KTable,Function,...) and KTable#leftJoin(KTable,Function,...) operations, for foreign key joins.

Method Summary

Modifier and Type	Method and Description
static <K,KO> TableJoined<K,KO>	as(String name) Create an instance of TableJoined with base name for all components of the join, including internal topics created to complete the join.
static <K,KO> TableJoined<K,KO>	with(StreamPartitioner<K,Void> partitioner, StreamPartitioner<KO,Void> otherPartitioner) Create an instance of TableJoined with partitioner and otherPartitioner StreamPartitioner instances.
TableJoined<K,KO>	withName(String name) Set the base name used for all components of the join, including internal topics created to complete the join.
TableJoined<K,KO>	withOtherPartitioner(StreamPartitioner<KO,Void> otherPartitioner) Set the custom other StreamPartitioner to be used as part of computing the join.
TableJoined<K,KO>	withPartitioner(StreamPartitioner<K,Void> partitioner) Set the custom StreamPartitioner to be used as part of computing the join.

Methods inherited from class java.lang.Object

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

Method Detail

with

public static <K,KO> TableJoined<K,KO> with(StreamPartitioner<K,Void> partitioner,
                                            StreamPartitioner<KO,Void> otherPartitioner)

Create an instance of TableJoined with partitioner and otherPartitioner StreamPartitioner instances. null values are accepted and will result in the default partitioner being used.

Type Parameters:

K - this key type ; key type for the left (primary) table

KO - other key type ; key type for the right (foreign key) table

Parameters:

partitioner - a StreamPartitioner that captures the partitioning strategy for the left (primary) table of the foreign key join. Specifying this option does not repartition or otherwise affect the source table; rather, this option informs the foreign key join on how internal topics should be partitioned in order to be co-partitioned with the left join table. The partitioning strategy must depend only on the message key and not the message value, else the source table is not supported with foreign key joins. This option may be left null if the source table uses the default partitioner.

otherPartitioner - a StreamPartitioner that captures the partitioning strategy for the right (foreign key) table of the foreign key join. Specifying this option does not repartition or otherwise affect the source table; rather, this option informs the foreign key join on how internal topics should be partitioned in order to be co-partitioned with the right join table. The partitioning strategy must depend only on the message key and not the message value, else the source table is not supported with foreign key joins. This option may be left null if the source table uses the default partitioner.

Returns:

new TableJoined instance with the provided partitioners

as

public static <K,KO> TableJoined<K,KO> as(String name)

Create an instance of TableJoined with base name for all components of the join, including internal topics created to complete the join.

Type Parameters:

K - this key type ; key type for the left (primary) table

KO - other key type ; key type for the right (foreign key) table

Parameters:

name - the name used as the base for naming components of the join including internal topics

Returns:

new TableJoined instance configured with the name

withPartitioner

public TableJoined<K,KO> withPartitioner(StreamPartitioner<K,Void> partitioner)

Set the custom StreamPartitioner to be used as part of computing the join. null values are accepted and will result in the default partitioner being used.

Parameters:

partitioner - a StreamPartitioner that captures the partitioning strategy for the left (primary) table of the foreign key join. Specifying this option does not repartition or otherwise affect the source table; rather, this option informs the foreign key join on how internal topics should be partitioned in order to be co-partitioned with the left join table. The partitioning strategy must depend only on the message key and not the message value, else the source table is not supported with foreign key joins. This option may be left null if the source table uses the default partitioner.

Returns:

new TableJoined instance configured with the partitioner

withOtherPartitioner

public TableJoined<K,KO> withOtherPartitioner(StreamPartitioner<KO,Void> otherPartitioner)

Set the custom other StreamPartitioner to be used as part of computing the join. null values are accepted and will result in the default partitioner being used.

Parameters:

otherPartitioner - a StreamPartitioner that captures the partitioning strategy for the right (foreign key) table of the foreign key join. Specifying this option does not repartition or otherwise affect the source table; rather, this option informs the foreign key join on how internal topics should be partitioned in order to be co-partitioned with the right join table. The partitioning strategy must depend only on the message key and not the message value, else the source table is not supported with foreign key joins. This option may be left null if the source table uses the default partitioner.

Returns:

new TableJoined instance configured with the otherPartitioner

withName

public TableJoined<K,KO> withName(String name)

Set the base name used for all components of the join, including internal topics created to complete the join.

Parameters:

name - the name used as the base for naming components of the join including internal topics

Returns:

new TableJoined instance configured with the name