flink中设置addSource的实体类方法

在 Flink 中设置 addSource 的实体类方法，需要实现 SourceFunction 接口，其中包括两个方法：

run 方法：该方法是 SourceFunction 接口中的抽象方法，用于定义数据源的生成逻辑。在该方法中，需要使用 SourceContext 发出数据。
cancel 方法：该方法是 SourceFunction 接口中的抽象方法，用于停止数据源的生成逻辑。

下面是一个示例代码：

public class MySource implements SourceFunction<String> {

    private volatile boolean isRunning = true;

    @Override
    public void run(SourceContext<String> ctx) throws Exception {
        while (isRunning) {
            // 生成数据
            String data = "hello world";
            // 发出数据
            ctx.collect(data);
            // 等待 1 秒钟
            Thread.sleep(1000);
        }
    }

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

在上面的示例中，MySource 实现了 SourceFunction 接口，并重写了其中的 run 和 cancel 方法。在 run 方法中，使用 while 循环生成数据，并通过 SourceContext 发出数据。在 cancel 方法中，将 isRunning 标志位设置为 false，停止数据源的生成逻辑