Hi Marke, Ken is right. We can use split and select to achieve what you want.
Besides, I am thinking if there is a lot of ingesting signals with unique Id's, why not use one function and process different logic in the function. For example, we can call different methods in the function according to the value of the input "id field". This can make the code more simple and generic, IMO. Is it because the return types of these functions are different? Best, Hequn On Wed, Apr 3, 2019 at 7:17 AM Ken Krugler <kkrugler_li...@transpac.com> wrote: > 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 > > — 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 > >
