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 <tsreape...@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 <ingenieroandresan...@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 >> >
