Hi, I have a single stream which I need to split into x streams based on key type then apply different operators for them. Is it a valid solution to make a process function to create x side outputs ?

You can do that or just create a bunch of new streams by mapping/flatMapping the main stream.