Sorry, I was discussing this with Stephan before posting it here. Basically main wrapper holds an array with a custom object and because its size can change thoughtout the stream and users can customize their sources dynamically, it make it difficult to create a generic pojo or use tuple for this purpose. Basically I have a wrapper which extends an HashMap containing K,V -> (attribute name, object). Each object has a set of attributes that we use to identify it's type. No i'm using kryo because hashmap it's not supported. Thing is, I'll always have a dynamic array of objects which I'll have to serialize.
Hope this helps Thanks, Nuno -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
