要如何设置,List才可以识别成为Flink可序列化的类呢?
hi,咨询一个问题,我们在定义实体的时候,如果属性中使用了List,就会被识别成 generic type。这个要如何设置,才可以识别成为Flink可序列化的类,而不是使用kyro。 class pojo{ String name; List someList; } 在flink-core中存在ListSerializer,可是不知道要如何使用。*来自志愿者整理的FLINK邮件归档
Flink - 可序列化的类(不是POJO)
"是不是可以在apache flink中序列化不是POJO的类?我有一个实用程序类,它有许多函数,我想发送Source函数的实用程序类的对象,但flink抛出序列化异常。 主类: Utilities utilities = new Utilities();DataStream dataStream = env.addSource(new MySource(configData,utilities....
本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。