Apache Flink读取至少2条记录到触发器接收器

<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-java</artifactId>
  <version>1.14.0</version>
</dependency>
<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-streaming-java_2.12</artifactId>
  <version>1.14.0</version>
</dependency>

import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.api.functions.source.SourceFunction;

public class FlinkExample {

    public static void main(String[] args) throws Exception {
        // 创建 Flink 流执行环境
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        // 创建一个数据源，用于生成示例数据
        DataStream<String> source = env.addSource(new SourceFunction<String>() {
            private volatile boolean isRunning = true;

            @Override
            public void run(SourceContext<String> ctx) throws Exception {
                ctx.collect("record1");
                ctx.collect("record2");
                // 可以继续添加更多记录
            }

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

        // 将数据流发送到触发器接收器
        source.print();

        // 执行 Flink 作业
        env.execute("Flink Example");
    }
}

record1
record2