Flink CEP：对于不同类型的事件，使用哪种方法加入数据流？

假设我有两种不同类型的数据流，一种提供天气数据，另一种提供车辆数据，我想使用 Flink 对数据进行复杂的事件处理。

Flink 1.3.x 中哪种方法是正确的使用方法？我看到了不同的方法，如 Union、Connect、Window Join。基本上我只是想尝试一个简单的 CEP，如下所示：

IF weather is wet AND vehicle speed > 60 
WITHIN the last 10 seconds
THEN raise alert

Thanks!

在我看来，有两种方法可以解决这个问题：

1. 对不同类型的事件使用公共父类型，并通过以下方式连接两个流union使用CEP库之前的方法。

2. 您可以使用flink-siddhi使用 SiddhiCEP 处理流的包提供了同时描述多个数据流的模式（通过 SiddhiQL）的方法。有关更多信息flink-siddhi here: https://haoch.github.io/flink-siddhi/ https://haoch.github.io/flink-siddhi/。源代码可以在 GitHub 上找到：https://github.com/haoch/flink-siddhi https://github.com/haoch/flink-siddhi。 SiddhiCEP 和 SiddhiQL 的文档：https://docs.wso2.com/display/CEP420/SiddhiQL+Guide+3.1 https://docs.wso2.com/display/CEP420/SiddhiQL+Guide+3.1.

希望这些信息会有帮助。