flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Andres Angel <ingenieroandresan...@gmail.com>
Subject Re: Create Tuple Array dynamically fro a DS
Date Wed, 24 Jul 2019 02:27:58 GMT
Hello Weng,

thanks for your reply, however I'm struggling to somehow read the content
of my DS with the payload that defines how many fields the message contains
into a String. That is the reason why I thought into a map function for
that DS.

The Tuple part can change overtime can even pass from 3 or 4 to 2 then it
can change the whole time. How could I approach this challenge?

thanks so much

On Tue, Jul 23, 2019 at 10:23 PM Caizhi Weng <tsreaper96@gmail.com> wrote:

> Hi Andres,
> Are the payloads strings? If yes, one method is that you can store them as
> strings and process it further with user defined functions when you need to
> use them.
> Another method is that you can store them into arrays.
> Also, if the type of the first 3 fields are the same for the first and
> second payload, you can use a Tuple4<> and set the last element as null for
> the first payload.
> Andres Angel <ingenieroandresangel@gmail.com> 于2019年7月24日周三 上午10:09写道:
>> Hello everyone,
>> I need to create dynamically the size of my Tuple that feeds a DS, let me
>> explain it better. Let's assume the first payload I read has this format
>> "filed1,field2,field3", then this might require a Tuple3<> but my payload
>> later can be "field1,field2,field3,field4" then my Tuple might need to be
>> refine it on the flight and now be Tuple4<>.
>> How could I create this dynamically, any idea?
>> Thanks so much

View raw message