Dear Team, I was wondering if there is feature in flink that support conditional multi colect.
Conditons 1. A stream is being processed and being converted to another stream/List using flatMap. 2. The place where collector.collect() is being called can we have multiple other collectors also ? 3. Can we add conditional collectors? Like if cond1 - then collector1.collect(), elif cond2 then collector1.collect() and collector2.collect(). I already know that I can do this serially by calling the same source stream with a different flatMap and then convert and push using collector2 Thanks, Tauseef
