Re: Use different functions for different signal values

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

Re: Use different functions for different signal values

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

Use different functions for different signal values

Hi, I want to implement the following behavior: [image: 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? T