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

Apache Flink 是一个分布式流处理框架，用于处理无界和有界数据流

以下是一个简单的示例，演示了如何使用 Apache Flink 读取至少两条记录，并将其发送到触发器接收器。

首先，确保已将 Apache Flink 添加到项目的依赖项中。如果您使用的是 Maven，请在 pom.xml 文件中添加以下依赖项：

<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>

接下来，创建一个 Java 类，用于读取数据流并发送至少两条记录到触发器接收器：

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");
    }
}

在这个示例中，我们创建了一个简单的数据源，用于生成两条示例记录。然后，我们使用 source.print() 将数据流发送到触发器接收器（在这种情况下，是控制台）。

运行此代码后，您将在控制台上看到以下输出：