Module windows 

Time windows, the Windowed<K> output key, and a windowed output serde.

Structs

JoinWindows

A symmetric or asymmetric join window. A record at t matches the other side’s records with a timestamp in [t - before, t + after].

SessionWindowedSerde

Serde<Windowed<K>> that produces the JVM session output-topic format inner_key_bytes ‖ end:8B BE ‖ start:8B BE.

SessionWindows

Session windows. The records for a key form one session while they stay within gap of each other. gap is the inactivity gap.

SlidingWindows

Sliding windows (KIP-450).

TimeWindowedSerde

Serde<Windowed<K>> that produces the JVM output-topic format inner_key_bytes ‖ windowStart : 8-byte BE, with no end and no seqnum.

TimeWindows

Tumbling and hopping time windows, which are epoch-aligned.

Window

A time window in epoch milliseconds.

Windowed

An aggregation key tagged with its window. This is the output key of a windowed aggregation (KTable<Windowed<K>, V>).