Hi Marke, You can use DataStream.split() to create a SplitStream, and then call SplitStream.select() to create the three different paths to the three functions.
See https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/operators/#datastream-transformations <https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/operators/#datastream-transformations> — Ken > On Apr 2, 2019, at 8:41 AM, Marke Builder <marke.buil...@gmail.com> wrote: > > Hi, > > I want to implement the following behavior: > > <image.png> > There are a lot of ingest signals with unique Id's, I would use for each > signal set a special function. E.g. Signal1, Signal2 ==> function1, Signal3, > Signal4 ==> function2. > What is the recommended way to implement this pattern? > > Thanks! > -------------------------- Ken Krugler +1 530-210-6378 http://www.scaleunlimited.com Custom big data solutions & training Flink, Solr, Hadoop, Cascading & Cassandra
