Hi Sumeet, It still doesn't support side outputs in PyFlink.
>> Or do I have to replicate the input datastream and then apply record specific filters? I'm afraid that yes. Regards, Dian On Sun, Mar 21, 2021 at 5:20 PM Sumeet Malhotra <[email protected]> wrote: > Hi, > > I have a use case where I need to process incoming records on a Kafka > topic based on a certain record field that defines the record type. > > What I'm thinking is to split the incoming datastream into record-type > specific streams and then apply record-type specific stream processing on > each. What's the recommended way to achieve this in PyFlink? Are side > outputs supported in PyFlink (I couldn't find any reference in the > codebase)? Or do I have to replicate the input datastream and then apply > record specific filters? > > Thanks, > Sumeet >
