如何使用ApacheStorm作为复杂事件处理器
我一直在寻找如何将apache storm用作CEP的方法，但似乎有两个概念（流处理和复杂事件处理），在CEP中，您可以编写类似sql的查询，并在数据流上执行它们，如ESPER，但我在apache storm中找不到类似的东西，这是否意味着apache storm是一个数据流处理器而不是CEP？
共有2个答案
Storm提供了一个名为trident的高级api，其中包括类似sql的api。它的特点是微批量，就像火花流。但我认为低api是storm的核心，它几乎可以满足您的所有需求。
Storm是一个通用的分布式计算平台，设计用于处理流数据。我认为许多人使用它来获取传入流并将其写入某个数据库，或者不使用SQL。有一个Storm Esper库，用于在Storm bolt中运行Esper。
-
我有一个离散事件流进入我的系统，我需要根据每个事件的内容应用规则。另外，我想对这些流事件应用复杂的事件处理。 约束1.这些规则是用户提供的，并将动态更改。2.每当应用规则时，我不想重新启动我的系统。3.HA 4.只有成熟的开源解决方案 可能的方式...1.在Storm螺栓内运行Esper CEP 2。让口水流到Storm螺栓里 > 这会处理单事件规则和复杂事件吗？规则更改是否需要我的Storm重新
-
我有一个flink cep代码，可以从套接字读取数据并检测模式。假设模式（单词）为“警报”。如果单词alert出现五次或五次以上，则应创建一个警报。但我得到了一个输入不匹配错误。Flink版本为1.3.0。提前谢谢！！
-
我正在尝试了解Apache Flink CEP程序，该程序用于监控数据中心中的机架温度，如Flink官方文档所述。但是当我按照步骤使用mvn clean package创建jar并尝试使用命令执行包时 但我有以下错误， 我尝试了给出这里描述的类路径的不同变体，但得到了相同的错误。有人能指出我在运行程序时的错误吗？
-
我已经挣扎了几个小时想找到解决这个问题的办法... 我正在开发一个在线记分牌的游戏。玩家可以随时登录和退出。完成一场比赛后，玩家会看到记分牌，看到自己的排名，分数会自动提交。 记分牌显示球员的排名，排行榜。 记分牌在用户完成游戏（提交分数）和用户只想查看他们的排名时都使用。 这就是逻辑变得非常复杂的地方： > 如果用户已经登录，那么分数将首先提交。保存新记录后，记分牌将被加载。 用户可以随时登录和
-
我想根据具有相同标识符的两个事件来检测两个事件是否在定义的时间范围内发生。例如，如下所示： 下面示例中的My DoorEvent java类具有相同的结构。 我想检测id为1的门在打开后5分钟内关闭。为此，我尝试使用Apache flink CEP库。传入流包含来自20扇门的所有打开和关闭消息。 如何在中将门1的状态保存为打开，以便在步骤中我知道门1是关闭的门，而不是其他门？
-
我想创建一个自定义的nifi处理器，这样我就可以读取s7 plc数据。为此，我想将这个项目的java代码:https://github.com/s7connector/s7connector转换为一个nifi处理器。 因此，我已经下载了mvn包类型，就像webiste告诉的那样:https://medium.com/hashmapinc/creating-custom-processors-and