假设我有两种不同类型的数据流，一种提供天气数据，另一种提供车辆数据，我想使用flink对数据进行复杂的事件处理。
flink 1.3.x中的哪种方法是正确的方法？我看到了不同的方法，比如联合，连接，窗口连接。基本上我只想试试这样一个简单的cep：
IF weather is wet AND vehicle speed > 60
WITHIN the last 10 seconds
THEN raise alert谢谢！
假设我有两种不同类型的数据流，一种提供天气数据，另一种提供车辆数据，我想使用flink对数据进行复杂的事件处理。
flink 1.3.x中的哪种方法是正确的方法？我看到了不同的方法，比如联合，连接，窗口连接。基本上我只想试试这样一个简单的cep：
IF weather is wet AND vehicle speed > 60
WITHIN the last 10 seconds
THEN raise alert谢谢！
1条答案
按热度按时间kgsdhlau1#
在我看来，有两种方法可以解决这个问题：
对不同类型的事件使用公共父类型，并通过
union方法使用cep库之前。你可以用
flink-siddhi包来使用siddhicep处理流，它提供了一种方法来同时描述多个数据流的模式（通过siddhiql）。有关的详细信息flink-siddhi在这里：https://haoch.github.io/flink-siddhi/. github上提供了源代码：https://github.com/haoch/flink-siddhi. siddhicep和siddhiql文件：https://docs.wso2.com/display/cep420/siddhiql+guide+3.1.希望这些信息能有所帮助。