要实现自定义 Flink Source，可以通过继承 RichSourceFunction 类来实现。在 RichSourceFunction 中，可以重写 run(SourceContext<T> ctx) 方法来控制数据的下发。
具体来说，可以在 run(SourceContext<T> ctx) 方法中使用一个循环来处理数据流，每次处理完一批数据后，使用 ctx.collect() 方法将结果发送给下游算子，然后等待一段时间再下发下一批数据。可以使用 Thread.sleep() 方法来模拟等待时间。
以下是一个简单的示例代码：
public class MyCustomSource extends RichSourceFunction<String> {
private List<String> dataList;
private int index;
@Override
public void open(Configuration parameters) throws Exception {
super.open(parameters);
dataList = new ArrayList<>(); // 初始化数据列表
// 加载数据到 dataList 中
}
@Override
public void close() throws Exception {
super.close();
// 关闭资源等操作
}
@Override
public void run(SourceContext<String> ctx) throws Exception {
while (true) {
// 处理当前批次的数据
for (int i = index; i < dataList.size(); i++) {
String data = dataList.get(i);
// 处理数据，例如过滤、转换等操作
// ...
// 将处理后的数据发送给下游算子
ctx.collect(data);
}
// 等待一段时间后下发下一批数据
Thread.sleep(1000L); // 等待1秒钟
index = index + dataList.size(); // 更新下标值，以便下次处理下一批数据
}
}
}
在上面的代码中，MyCustomSource 类继承了 RichSourceFunction 类，并实现了 open()、close()、run() 三个方法。在 run() 方法中，使用了一个无限循环来处理数据流，每次处理完一批数据后，使用 ctx.collect() 方法将结果发送给下游算子，然后等待一段时间再下发下一批数据。
