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

public class Windowed<K>
extends java.lang.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.windowedBy(Windows), KGroupedStream.windowedBy(SessionWindows)

Constructor Summary

Constructors

Constructor and Description
Windowed(K key, Window window)

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object obj)
int	hashCode()
K	key() Return the key of the window.
java.lang.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 java.lang.String toString()

Overrides:

toString in class java.lang.Object

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object