Hi Ara,
The problem is, that type Window is a composite key of
"String-Long" that encoded your original key of type String the window
start time of type Long. Thus, even if two record have the same
"string-key" they might be different, because the belong to different
windows.
Try to insert a map(
Hi,
Is joining 2 streams based on Windowed keys supposed to work?
I have 2 KTables:
- KTable, T> events: I process events and aggregate events
that have a common criteria using aggregateByKey and UnlimitedWindows as window
(for now)
- KTable, S> hourlyStats: I calculate some stats using
aggreg
