Thanks Matthias,
That's far cleaner :)
Cheers,
Liam Clarke
On Mon, Dec 3, 2018 at 4:59 PM Matthias J. Sax
wrote:
> The nulls are expected.
>
> It's not about expired session windows though: sessions window are
> stored as `<(key,start-timestamp,end-timestamp), value>`. If the window
> boundar
The nulls are expected.
It's not about expired session windows though: sessions window are
stored as `<(key,start-timestamp,end-timestamp), value>`. If the window
boundaries changed due to new incoming events (or maybe a merge of two
windows due to late arriving records), the window is updated via
Hi all,
Using
I am using a session window of 1 minute to detect and prevent duplicated
events within the window using reduce() to preserve the first seen value
and accumulate how often duplicates were seen, I'm then converting the
windowed KTable into a stream to continue processing events.
Howe
