flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Hequn Cheng <chenghe...@gmail.com>
Subject Re: Use different functions for different signal values
Date Wed, 03 Apr 2019 05:15:15 GMT
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_lists@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.builder@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
>
>

Mime
View raw message