Re: Best way to deriving streams from another one

Have a look at side outputs in the documentation, they allow you to emit to multiple streams (of different types!) with a ProcessFunction. On 10.09.2017 22:15, AndreaKinn wrote: Hi, I have a data stream resulting from an operation executed on a data stream of data. Essentially I want to obtain

Best way to deriving streams from another one

Hi, I have a data stream resulting from an operation executed on a data stream of data. Essentially I want to obtain two different streams from that one to send their to different cassandra tables. I.e.: datastream 0 composed by Tuple3 I want to have: a datastream 1 composed