org.apache.kafka.streams.kstream

Class Grouped<K,V>

java.lang.Object

org.apache.kafka.streams.kstream.Grouped<K,V>

Type Parameters:

K - the key type

V - the value type

public class Grouped<K,V>
extends Object

The class that is used to capture the key and value Serdes and set the part of name used for repartition topics when performing KStream.groupBy(KeyValueMapper, Grouped), KStream.groupByKey(Grouped), or KTable.groupBy(KeyValueMapper, Grouped) operations. Note that Kafka Streams does not always create repartition topics for grouping operations.

Field Summary

Fields

Modifier and Type	Field and Description
protected Serde<K>	keySerde
protected String	name
protected Serde<V>	valueSerde

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Grouped(Grouped<K,V> grouped)

Method Summary

Modifier and Type	Method and Description
static <K,V> Grouped<K,V>	as(String name) Create a Grouped instance with the provided name used as part of the repartition topic if required.
static <K> Grouped	keySerde(Serde<K> keySerde) Create a Grouped instance with the provided keySerde.
static <V> Grouped	valueSerde(Serde<V> valueSerde) Create a Grouped instance with the provided valueSerde.
static <K,V> Grouped<K,V>	with(Serde<K> keySerde, Serde<V> valueSerde) Create a Grouped instance with the provided keySerde and valueSerde.
static <K,V> Grouped<K,V>	with(String name, Serde<K> keySerde, Serde<V> valueSerde) Create a Grouped instance with the provided name, keySerde, and valueSerde.
Grouped<K,V>	withKeySerde(Serde<K> keySerde) Perform the grouping operation using the provided keySerde for serializing the key.
Grouped<K,V>	withName(String name) Perform the grouping operation with the name for a repartition topic if required.
Grouped<K,V>	withValueSerde(Serde<V> valueSerde) Perform the grouping operation using the provided valueSerde for serializing the value.

Methods inherited from class java.lang.Object

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

Field Detail

keySerde

protected final Serde<K> keySerde

valueSerde

protected final Serde<V> valueSerde

name

protected final String name

Constructor Detail

Grouped

protected Grouped(Grouped<K,V> grouped)

Method Detail

as

public static <K,V> Grouped<K,V> as(String name)

Create a Grouped instance with the provided name used as part of the repartition topic if required.

Parameters:

name - the name used for a repartition topic if required

Returns:

a new Grouped configured with the name

See Also:

KStream.groupByKey(Grouped), KStream.groupBy(KeyValueMapper, Grouped), KTable.groupBy(KeyValueMapper, Grouped)

keySerde

public static <K> Grouped keySerde(Serde<K> keySerde)

Create a Grouped instance with the provided keySerde. If null the default key serde from config will be used.

Parameters:

keySerde - the Serde used for serializing the key. If null the default key serde from config will be used

Returns:

a new Grouped configured with the keySerde

See Also:

KStream.groupByKey(Grouped), KStream.groupBy(KeyValueMapper, Grouped), KTable.groupBy(KeyValueMapper, Grouped)

valueSerde

public static <V> Grouped valueSerde(Serde<V> valueSerde)

Create a Grouped instance with the provided valueSerde. If null the default value serde from config will be used.

Parameters:

valueSerde - the Serde used for serializing the value. If null the default value serde from config will be used

Returns:

a new Grouped configured with the valueSerde

See Also:

KStream.groupByKey(Grouped), KStream.groupBy(KeyValueMapper, Grouped), KTable.groupBy(KeyValueMapper, Grouped)

with

public static <K,V> Grouped<K,V> with(String name,
                                      Serde<K> keySerde,
                                      Serde<V> valueSerde)

Create a Grouped instance with the provided name, keySerde, and valueSerde. If the keySerde and/or the valueSerde is null the default value for the respective serde from config will be used.

Parameters:

name - the name used as part of the repartition topic name if required

keySerde - the Serde used for serializing the key. If null the default key serde from config will be used

valueSerde - the Serde used for serializing the value. If null the default value serde from config will be used

Returns:

a new Grouped configured with the name, keySerde, and valueSerde

See Also:

KStream.groupByKey(Grouped), KStream.groupBy(KeyValueMapper, Grouped), KTable.groupBy(KeyValueMapper, Grouped)

with

public static <K,V> Grouped<K,V> with(Serde<K> keySerde,
                                      Serde<V> valueSerde)

Create a Grouped instance with the provided keySerde and valueSerde. If the keySerde and/or the valueSerde is null the default value for the respective serde from config will be used.

Parameters:

keySerde - the Serde used for serializing the key. If null the default key serde from config will be used

valueSerde - the Serde used for serializing the value. If null the default value serde from config will be used

Returns:

a new Grouped configured with the keySerde, and valueSerde

See Also:

KStream.groupByKey(Grouped), KStream.groupBy(KeyValueMapper, Grouped), KTable.groupBy(KeyValueMapper, Grouped)

withName

public Grouped<K,V> withName(String name)

Perform the grouping operation with the name for a repartition topic if required. Note that Kafka Streams does not always create repartition topics for grouping operations.

Parameters:

name - the name used for the processor name and as part of the repartition topic name if required

Returns:

a new Grouped instance configured with the name

withKeySerde

public Grouped<K,V> withKeySerde(Serde<K> keySerde)

Perform the grouping operation using the provided keySerde for serializing the key.

Parameters:

keySerde - Serde to use for serializing the key. If null the default key serde from config will be used

Returns:

a new Grouped instance configured with the keySerde

withValueSerde

public Grouped<K,V> withValueSerde(Serde<V> valueSerde)

Perform the grouping operation using the provided valueSerde for serializing the value.

Parameters:

valueSerde - Serde to use for serializing the value. If null the default value serde from config will be used

Returns:

a new Grouped instance configured with the valueSerde