RE: How to deal with dynamic types

2018-01-26 Thread Newport, Billy
...@gmail.com] Sent: Monday, December 11, 2017 10:13 AM To: user@flink.apache.org Subject: How to deal with dynamic types Hi, I am trying some initial samples with flink. I have one doubt regarding data types. Flink support data types Tuple(max 25 fields), Java POJOs, Primitive types, Regular classes etc

Re: How to deal with dynamic types

2017-12-11 Thread Piotr Nowojski
Hi, For truly dynamic class you would need a custom TypeInformation or TypeDeserializationSchema and store the fields on some kind of Map. Maybe something could be done with inheritance if records that always share the same fields could be deserialized to some specific class

How to deal with dynamic types

2017-12-11 Thread madan
Hi, I am trying some initial samples with flink. I have one doubt regarding data types. Flink support data types Tuple(max 25 fields), Java POJOs, Primitive types, Regular classes etc., In my case I do not have fixed type. I have meta data with filed names & its types. For ex., (Id:int,