Flink自定义source function用单线程产生数据流

可以通过继承 `RichSourceFunction` 类来自定义一个数据源函数，然后在 `run()` 方法中产生数据流。为了让数据流在单线程中生成，可以使用 `Thread.sleep()` 方法来模拟数据产生的延迟，例如：

public class CustomSource extends RichSourceFunction<String> {
    private volatile boolean isRunning = true;

    @Override
    public void run(SourceContext<String> ctx) throws Exception {
        while (isRunning) {
            // 模拟每秒钟产生一条数据
            Thread.sleep(1000);
            String data = "Data-" + System.currentTimeMillis();
            ctx.collect(data);
        }
    }

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

在上面的例子中，每秒钟产生一条数据，并且使用 `System.currentTimeMillis()` 来生成数据的唯一标识。你可以根据自己的需求来修改数据的生成方式。注意，这个例子是在单线程中生成数据流，但是 `collect()` 方法是阻塞的，也就是说当数据流被消费时，它会等待直到有新的数据产生。如果你的数据产生速度过快，可能会导致程序的内存被耗尽，所以需要根据实际情况来控制数据的产生速度。