Flink 通用元素序列化

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

Flink 通用元素序列化

戴嘉诚
Hey all
        大家好,我这里在使用Flink自带的对象序列化类中,例如:ListSerializer、MapSerializer等等,发现java内部通用都大部分都包含了,但是现在发现貌似没有set集合的序列化?这个是什么原因呢?如果我需要用,是要自己自定义一个吗?还是类似jdk源码那样,把Set集合,转成HashMap集合,然后用MapSerializer?
如果我自定一个,那么为什么源码中为List、map都包含了,就单单set集合不包含呢?是否有其他原因导致呢?


谢谢大家