org.apache.kafka.streams.kstream

Interface KGroupedTable<K,V>

Type Parameters:

K - Type of primary keys

V - Type of value changes

@InterfaceStability.Unstable
public interface KGroupedTable<K,V>

KGroupedTable is an abstraction of a grouped changelog stream from a primary-keyed table, usually on a different grouping key than the original primary key.

It is an intermediate representation after a re-grouping of a KTable before an aggregation is applied to the new partitions resulting in a new KTable.

Method Summary

Methods

Modifier and Type	Method and Description
<T> KTable<K,T>	aggregate(Initializer<T> initializer, Aggregator<K,V,T> adder, Aggregator<K,V,T> substractor, Serde<T> aggValueSerde, String name) Aggregate updating values of this stream by the selected key into a new instance of KTable.
<T> KTable<K,T>	aggregate(Initializer<T> initializer, Aggregator<K,V,T> adder, Aggregator<K,V,T> substractor, String name) Aggregate updating values of this stream by the selected key into a new instance of KTable using default serializers and deserializers.
KTable<K,Long>	count(String name) Count number of records of this stream by the selected key into a new instance of KTable.
KTable<K,V>	reduce(Reducer<V> adder, Reducer<V> subtractor, String name) Combine updating values of this stream by the selected key into a new instance of KTable.

Method Detail

reduce

KTable<K,V> reduce(Reducer<V> adder,
                 Reducer<V> subtractor,
                 String name)

Combine updating values of this stream by the selected key into a new instance of KTable.

Parameters:

adder - the instance of Reducer for addition

subtractor - the instance of Reducer for subtraction

name - the name of the resulted KTable

Returns:

a KTable with the same key and value types as this KGroupedTable, containing aggregated values for each key

aggregate

<T> KTable<K,T> aggregate(Initializer<T> initializer,
                        Aggregator<K,V,T> adder,
                        Aggregator<K,V,T> substractor,
                        Serde<T> aggValueSerde,
                        String name)

Aggregate updating values of this stream by the selected key into a new instance of KTable.

Type Parameters:

T - the value type of the aggregated KTable

Parameters:

initializer - the instance of Initializer

adder - the instance of Aggregator for addition

substractor - the instance of Aggregator for subtraction

aggValueSerde - value serdes for materializing the aggregated table, if not specified the default serdes defined in the configs will be used

name - the name of the resulted table

Returns:

a KTable with same key and aggregated value type T, containing aggregated values for each key

aggregate

<T> KTable<K,T> aggregate(Initializer<T> initializer,
                        Aggregator<K,V,T> adder,
                        Aggregator<K,V,T> substractor,
                        String name)

Aggregate updating values of this stream by the selected key into a new instance of KTable using default serializers and deserializers.

Type Parameters:

T - the value type of the aggregated KTable

Parameters:

initializer - the instance of Initializer

adder - the instance of Aggregator for addition

substractor - the instance of Aggregator for subtraction

name - the name of the resulted KTable

Returns:

a KTable with same key and aggregated value type T, containing aggregated values for each key

count

KTable<K,Long> count(String name)

Count number of records of this stream by the selected key into a new instance of KTable.

Parameters:

name - the name of the resulted KTable

Returns:

a KTable with same key and Long value type as this KGroupedTable, containing the number of values for each key