在apache flink中不可能序列化不是POJO的类吗?我有一个实用程序类,它有许多函数,我想向Source函数发送该实用程序类的对象,但是flink抛出序列化异常。
主类:
Utilities utilities = new Utilities();
DataStream<MyData> dataStream = env.addSource(new MySource(configData,utilities))
实用程序类:
public class Utilities {
public Utilities() {
//default constructor
}
public String fun1() {
//Do something
}
public String fun2() {
//Do something
}
}
使实用程序
实现可序列化
。