Flink 自定义数据源：使用实体 Bean 类传输数据

在 Flink 中，可以通过实现 SourceFunction 接口来自定义数据源。在 addSource 方法中，可以传入一个实现了 SourceFunction 接口的类的实例作为数据源。如果要传输自定义的实体 bean 类，可以在 SourceFunction 的 run 方法中使用 Collectors 来将数据发送出去：

public class MySourceFunction implements SourceFunction<MyBean> {

    private volatile boolean isRunning = true;

    @Override
    public void run(SourceContext<MyBean> ctx) throws Exception {
        while (isRunning) {
            // 从数据源中获取数据
            MyBean myBean = getDataFromSource();
            // 将数据发送出去
            ctx.collect(myBean);
        }
    }

    @Override
    public void cancel() {
        isRunning = false;
    }
}

在上面的例子中，MyBean 是自定义的实体 bean 类，getDataFromSource 是从数据源中获取数据的逻辑，可以根据实际情况自行实现。ctx.collect(myBean) 会将获取到的数据发送出去，Flink 会将其作为数据流处理。