esper-我们可以使用esper进行流水线时尚处理吗？

6mzjoqzu 于 2021-06-21 发布在 Storm

关注(0)|答案(1)|浏览(356)

我想以流水线的方式使用esper进行一些事件处理。我需要检查每个事件的多个案例。例如，我想针对以下情况运行传入的数据。我该怎么做？最好的方法是什么？
case 1=“如果当前级别比最近5个连续值的平均值高400%，则将事件标记为exception-1”
case 2=“如果当前级别值为空，则标记为异常-2”
case 3=“如果case 2和case 3不匹配，则数据被标记为‘安全’”
下面是我想做的事情的大致描述

if (case1) { 
       mark with Exception 1 
     }

     if (case2) {
       mark with Exception 2 
     }

     if (none of the above cases matches) {
         mark as safe 
     }

apache-storm complex-event-processing esper

来源：https://stackoverflow.com/questions/38583695/esper-can-we-do-pipelined-fashion-processing-using-esper

1条答案

按热度按时间

czfnxgou1#

像这样的

on Event 
insert into OutputStream select 'Exception 1' as label, * where level_detected > 400
insert into OutputStream select 'Exception 2' as label, * where level_detected = null
insert into OutputStream select 'safe' as label, *

您没有询问如何检测“当前级别是否比最近5个连续值的平均值高400%”，因此这不是我的答案的一部分。
用于分割流的esper文档

赞(0）回复(0）举报 2021-06-21

我来回答

esper-我们可以使用esper进行流水线时尚处理吗？

1条答案

相关问题

热门标签

最新问答