Multi-stream: per-key tumbling windows with nested groupingBy

Group by the key, then by the window inside it, and one pass gives a per-user activity profile over time. Two TreeMaps keep both axes in order so two runs produce identical output.

Full code & output

This topic is available to signed-in members.