Hi, I am joining two streams with a session window and want to emit a joined (early) result for every element arriving on one of the streams.
Currently the code looks like this: s1.join(s2) .where(s1.id).equalTo(s2.id) .window(EventTimeSessionWindows.withGap(Time.minutes(15))) // trigger(?) .apply(...custom code..) What I am missing is the right trigger ala "withEarlyFiring" - do I need to implement my on trigger for this and if yes, what kind of functionality must be present to not break the session window semantics? Thanks in advance, Johannes
