org.apache.kafka.streams.kstream

Class Windowed<K>

java.lang.Object

org.apache.kafka.streams.kstream.Windowed<K>

Type Parameters:

K - type of the key

@InterfaceStability.Unstable
public class Windowed<K>
extends Object

The result key type of a windowed stream aggregation.

If a KStream gets grouped and aggregated using a window-aggregation the resulting KTable is a so-called "windowed KTable" with a combined key type that encodes the corresponding aggregation window and the original record key. Thus, a windowed KTable has type <Windowed<K>,V>.

See Also:

KGroupedStream.count(Windows, String), KGroupedStream.count(Windows, org.apache.kafka.streams.processor.StateStoreSupplier), KGroupedStream.count(SessionWindows, String), KGroupedStream.count(SessionWindows, org.apache.kafka.streams.processor.StateStoreSupplier), KGroupedStream.reduce(Reducer, Windows, String), KGroupedStream.reduce(Reducer, Windows, org.apache.kafka.streams.processor.StateStoreSupplier), KGroupedStream.reduce(Reducer, SessionWindows, String), KGroupedStream.reduce(Reducer, SessionWindows, org.apache.kafka.streams.processor.StateStoreSupplier), KGroupedStream.aggregate(Initializer, Aggregator, Windows, org.apache.kafka.common.serialization.Serde, String), KGroupedStream.aggregate(Initializer, Aggregator, Windows, org.apache.kafka.streams.processor.StateStoreSupplier), KGroupedStream.aggregate(Initializer, Aggregator, Merger, SessionWindows, org.apache.kafka.common.serialization.Serde, org.apache.kafka.streams.processor.StateStoreSupplier), KGroupedStream.aggregate(Initializer, Aggregator, Merger, SessionWindows, org.apache.kafka.common.serialization.Serde, String)

Constructor Summary

Constructors

Constructor and Description
Windowed(K key, Window window)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	equals(Object obj)
int	hashCode()
K	key() Return the key of the window.
String	toString()
Window	window() Return the window containing the values associated with this key.

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

Windowed

public Windowed(K key,
        Window window)

Method Detail

key

public K key()

Return the key of the window.

Returns:

the key of the window

window

public Window window()

Return the window containing the values associated with this key.

Returns:

the window containing the values

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object