flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Martin Neumann <mneum...@sics.se>
Subject Splitting Streams
Date Thu, 03 Sep 2015 09:56:14 GMT

I have a Stream of json objects of several different types. I want to split
this stream into several streams each of them dealing with one type. (so
its not partitioning)

The only Way I found so far is writing a bunch of filters and connect them
to the source directly. This way I will have a lot of duplicated logic.
I'm basically looking for a single operator that can have multiple output
streams of different types.

cheers Martin

View raw message