Re: Use different functions for different signal values

Posted by Ken Krugler on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Use-different-functions-for-different-signal-values-tp27036p27042.html

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 <[hidden email]> 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