如何添加新事件闪烁CEP数据流？

Question

我正在使用flink 1.5.2解决CEP问题。

我的数据来自一个列表，当系统运行时，其他一些进程将向该列表添加新的事件对象。它不是套接字或网络消息。我一直在阅读官方网站的示例。以下是我想我应该做的步骤。

1. 使用env创建数据流。fromCollection（列表）
2. 定义图案图案
3. 使用CEP获取PatternStream。模式（数据流，模式）
4. 使用pattern\u流。选择（…实现选择接口…）以数据流的形式获取复杂事件结果

但是我的输入流应该是无界的。我在DataStream中没有找到任何add（）方法

Answer 1

当使用预先固定的有界输入集时，集合仅适合作为Flink的输入源，例如在编写测试或只是实验时。如果您想要一个无界流，您需要选择不同的源，例如套接字或像Kafka这样的消息队列系统。

套接字很容易用于实验。在Linux和MacOS系统上，您可以使用

nc -lk 9999

要创建Flink可以绑定到端口9999上的套接字，您作为nc（netcat）输入提供的任何内容都将流式传输到Flink作业中，每次传输一行。Netcat也可用于Windows，但不是预装的。

然而，您不应该计划在生产中使用套接字，因为它们不能重绕（这对于在故障恢复期间使用Flink获得准确结果至关重要）。