Module join_window 

The retainDuplicates window store for stream-stream joins.

It uses composite WindowKeySchema keys with a per-store incrementing seqnum, and it stores RAW values with no ValueAndTimestamp wrap. fetch returns every duplicate in a range.

Structs

JoinWindowBytesStore

Traits

JoinWindowStore

A typed windowed store that retains duplicates.