flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jack Huang <jackhu...@mz.com>
Subject Cannot use WindowedStream.fold with EventTimeSessionWindows
Date Wed, 17 Aug 2016 01:21:52 GMT
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.UnsupportedOperationException: Fold cannot be used with a
merging WindowAssigner.

​

Does anyone have a workaround?



Thanks,
Jack

Mime
View raw message