flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nragon <nuno.goncal...@wedotechnologies.com>
Subject Re: Custom Serializers
Date Fri, 15 Sep 2017 13:34:04 GMT
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/

Mime
View raw message