K
public class Windowed<K> extends Object
KGroupedStream.aggregate(Initializer, Aggregator, Windows, org.apache.kafka.common.serialization.Serde, String)
<Windowed<K>, V>
Windowed(K key, Window window)
boolean
equals(Object obj)
int
hashCode()
key()
String
toString()
Window
window()
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
public Windowed(K key, Window window)
public K key()
public Window window()
public String toString()
toString
Object
public boolean equals(Object obj)
equals
public int hashCode()
hashCode