提问者:小点点

Flink-类的可序列化(不是POJO)


在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  
    }   
}

共1个答案

匿名用户

使实用程序实现可序列化