Hi Till,
The session I am dealing with does not have a reliable "end-of-session"
event. It could stop sending events all of sudden or it could keep sending
events forever. I need to be able to determine when a session expire due to
inactivity or to kill off a session if it lives longer than it sho
Hi Jack,
the problem with session windows and a fold operation, which is an
incremental operation, is that you don't have a way to combine partial
folds when merigng windows. As a workaround you have to specify a window
function where you get an iterator over all your window elements and then
perf
Hi all,
I want to window a series of events using SessionWindow and use fold
function to incrementally aggregate the result.
events
.keyBy(_.id)
.window(EventTimeSessionWindows.withGap(Time.minutes(1)))
.fold(new Session)(eventFolder)
However I get
java.lang.UnsupportedOperationEx
