flink中addSource中重写run方法

在 Flink 中，可以使用 addSource 方法添加一个数据源。addSource 方法需要传入一个继承自 SourceFunction 接口的实现类对象，该接口中定义了一个 run 方法，用于定义数据源的具体行为。因此，在使用 addSource 方法时，需要重写 run 方法来实现自定义的数据源逻辑。

下面是一个简单的示例，展示了如何在 run 方法中实现一个自定义的数据源逻辑：

public class MySource implements SourceFunction<String> {

    private volatile boolean isRunning = true;

    @Override
    public void run(SourceContext<String> ctx) throws Exception {
        while (isRunning) {
            String message = getMessage(); // 从数据源获取数据
            ctx.collect(message); // 发送数据到 Flink 流处理程序
            Thread.sleep(1000); // 模拟数据源每秒产生一条数据
        }
    }

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

    private String getMessage() {
        // 从数据源获取数据的具体逻辑
    }
}

在上面的示例中，run 方法中定义了一个 while 循环，不断地从数据源获取数据，并使用 collect 方法将数据发送到 Flink 流处理程序中。同时，为了模拟数据源每秒产生一条数据的情况，使用了 Thread.sleep 方法。cancel 方法用于停止数据源的运行。

需要注意的是，由于 run 方法是在一个单独的线程中运行的，因此需要使用 volatile 关键字来保证 isRunning 变量的可见性，以便在 cancel 方法中正确地停止数据源的运行