Re: Conditional multi collect in flink

2023-12-04 Thread Ken Krugler
Hi Tauseef, It sounds like you want to use side outputs (via a ProcessFunction, versus a FlatMap). — Ken > On Dec 4, 2023, at 8:23 AM, Tauseef Janvekar > wrote: > > Dear Team, > > I was wonderin

Conditional multi collect in flink

2023-12-04 Thread Tauseef Janvekar
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.