Flink CEP：哪种方法可以连接不同类型事件的数据流？
假设我有两种不同类型的数据流，一种提供天气数据，另一种提供车辆数据，我想使用Flink对数据进行复杂的事件处理。
Flink 1.3中的哪种方法。x是正确的使用方法吗？我看到了不同的方法，如联合、连接、窗口连接。基本上，我只想尝试这样一个简单的CEP：
IF weather is wet AND vehicle speed > 60
WITHIN the last 10 seconds
THEN raise alert
谢谢
共有1个答案
在我看来，有两种方法可以解决这个问题：
>
对不同类型的事件使用通用父类型，并在使用CEP库之前通过Union方法连接两个流。
您可以使用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指南3.1。
希望这些信息会有所帮助。
-
我在Java中有两个几乎相同的方法。唯一的区别是它们有不同的参数类型。它们使用泛型并返回输入参数的类型T。我怎样才能摆脱重复的代码？下面是我的两个方法。最后，它们都使用不同的类型调用Spring。否则，方法是相同的。
-
问题内容： 我正在写一个方法，该方法应接受不共享除父对象以外的父类型的两种类型之一的对象作为其参数。例如，类型为Dreams和Garlic。您可以同时和。我想有一个方法，可以将Dreams和Garlic都接受为其参数。 Garlic和dreams都是某些库的一部分，因此让它们实现ICrushable接口（以便我可以编写）是不可行的。 我的方法主体很长，因此重载将意味着复制代码。丑陋。我确定我可以使
-
根据本·施耐德曼（Ben Shneiderman）的分类，信息可视化的数据分为：一维数据、二维数据、三维数据、多维数据、时态数据、层次数据和网络数据。大数据可视化研究的领域主要包含：多维数据、时态数据、层次数据和网络数据。 时态数据的可视化 时间数据广泛存在于不同的应用中，例如医疗记录、项目管理或历史介绍。数据集中的每一项包含时间信息，如开始和结束时间。用户潜在的需求是搜索在某些事件或时刻之间、之
-
本文向大家介绍11种ASP连接数据库的方法，包括了11种ASP连接数据库的方法的使用技巧和注意事项，需要的朋友参考一下 ASP连接数据库的11种方法——本文总结了使用ASP链接各种数据库的方法： 1.Access数据库的DSN-less连接方法: 2.Access OLE DB连接方法： 3.SQL server连接方法： 4.SQL server OLE DB连接方法: 5.Oracle 连接方
-
本文向大家介绍Java连接各种数据库的方法，包括了Java连接各种数据库的方法的使用技巧和注意事项，需要的朋友参考一下 本文实例讲述了Java连接各种数据库的方法。分享给大家供大家参考。具体如下： 希望本文所述对大家的java程序设计有所帮助。
-
我想知道拥有包含几种类型的容器的方法。我知道那件事： 一个元组可以包含多种类型 如果我创建一个枚举 ，我可以创建一个