nesper

    0热度

    1回答

    是否可以嵌套这样的两个crontab上下文? create context Nest context A start (0, *, *, *, 1) end (0, *, *, *, 6), context B start (0, 8, *, *, *) end (0, 22, *, *, *) 第一个上下文是否决定第二个上下文? 如果是这样,我认为,A应该是自决定日子以来的第一个,并且第

    0热度

    1回答

    我敢肯定,这种说法作品在艾斯波: /* query from table TableA when receive event PriceEvent */ ON PriceEvent p SELECT a.SymbolA, p.price FROM TableA a WHERE a.Symbol = p.Symbol 但这一说法引发错误: /* join table TableA wit

    1热度

    1回答

    我如何可以调用的方法类似 select udf(a,b) from Event.win:length_batch(5) 中并重新打印尺寸5的窗口。假设我发送了以下事件: runtime.sendEvent(new Event(1,2)); runtime.sendEvent(new Event(3,4)); runtime.sendEvent(new Event(4,2)); runti

    0热度

    1回答

    我想要在下面两个上下文中指定的时间之间选择相同的语句。但是我没有输出。当B处于活动状态并且C在单个语句中使用嵌套上下文处于活动状态时,如何获得输出? create context A context B start (0, 12, *, *, *) end (0, 18, *, *, *), context C start (0, 20, *, *, *) end (0, 23

    -1热度

    1回答

    我使用Nesper作为CEP引擎来处理我的应用程序中的事件。 我想下面的EPL声明型号: 事件的Value场的平均值在有限窗口时间。 如果这些平均值中的任何一个匹配了1期望值,则会生成一个事件。 我此建模为: SELECT ( (AVG(ParameterEvent1.Value) = 1) OR (AVG(ParameterEvent2.Value) = 1) ... (AVG(Param

    0热度

    1回答

    是否有可能创建一个主键和一个设置为辅助列的表,就像一个哈希表的值列表中的表? 是这样的: create table T (id int primary key, list HashSet) 在名单将举行有关所发生过的窗口大小的主键的所有属性。 编辑: 这是输出我得到。我要的是保持独特OCCURENCES的数量在ID 1,2和3 到达如果Occurence 2在ID 1到达3倍我还是只想要1独树

    0热度

    1回答

    我想用NEsper测量具有唯一标识的汽车的时间。我的问题是,道路上有几辆车。这条路有预定义的步骤。我想要开始停止每一辆独一无二的汽车的时间,直到这款汽车获得最后一步。 select ice.* from pattern[ice = IncomingCarEvent -> every timer:interval(1 sec) and not LastStepEvent] 问题是,我不知道如何将

    0热度

    1回答

    我有窗口长度的问题。 我的条件:如果事件长度内发生 1输出将触发3 2输出驳回如果事件长度后发生3 实施例: 事件序列: 1: 2 :乙 3:C 4:d 5:电子 6: 7:C 8:d 9:电子 10:F 11:乙 事件规则: Z = A - >乙 期望输出位:Z将在索引号2发生自赢:长度(3) 我的问题:该输出端Z也触发的索引号11 eventhought超过WIN:长度(3) 我简单的代码:

    0热度

    1回答

    Esper是否可以通过输入管理时间戳。我使用的文件是这样的: 143 Sat Sep 12 14:43:05 CEST 2009 149 Sat Sep 12 14:43:06 CEST 2009 149 Sat Sep 12 14:43:09 CEST 2009 143 Sat Sep 12 14:43:10 CEST 2009 149 Sat Sep 12 14:43:12 CEST

    0热度

    1回答

    我有esper processer配置为在kafka中侦听邮件。 通常select * from events.win:time(2 min)将触发最近2分钟内的所有事件 现在,如果最后2分钟没有卡夫卡消息,我想触发通知。 我应该怎么处理它,当我喜欢写东西 select * from events(Ip='1.1.1.1').win:time(2 min) 这不会有匹配的邮件/事件和超能力者不触发