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.
— Ken
Hi,
I want to implement the following behavior:
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!
--------------------------