esper

-1热度

1回答

即时消息全新的Esper，所以如果下面的问题听起来很愚蠢，请不要开枪。我正在将POJO事件发送给esper实例。该POJO。有一些属性，具体如下： MyEventPOJO { final String sourceIP; final String destIP; final Calendar transmissionTime; final List<WorkingDay> Working

0热度

1回答

复杂事件处理-Esper

我想知道是否有任何关于Esper源代码的组件如何协作以产生查询结果的信息（例如图表）。例如，当应用选择查询时，数据是存储在一个数组中，Esper的源代码在哪里发生？

0热度

1回答

Esper：event_batch unsing timestamp event of event-POJO

我对esper有一个非常具体但很短的问题。我在esper中获得了event-POJO，它们都以timeStamp作为属性。我需要做一个time_batch窗口，但是我必须根据事件的时间戳做窗口。时间戳将是一个很长的值。我正在网上搜索几个小时，找不到任何可以帮助我的东西。

0热度

1回答

Esper：当值超过阈值时抛出事件

我是Espers新手，尝试实施警报系统。当项目值超过阈值时，我需要抛出一个事件。例如，对于一辆汽车，我想在属性坦克超过40值时获得一个事件，而当此值回到40以下时，我想获得一个事件。我已经尝试了很多Esper的功能，但没有任何效果。我想要做这样的事情，但它不能很好地工作： insert into AlertEvt select b from pattern[t=Car while (t.ta

0热度

1回答

EPL模式匹配最新的A和所有B与滤波器

我试图找到一个EPL模式，将匹配最新的A，其次是任何&所有B（prop1 = A.prop1）。使用在Esper's documentation定义相同序列... A1 B1 C1 B2 A2 D1 A3 B3 E1 A4 F1 B4 我要寻找，将匹配{A1，B1} {A1，B2}模式{A3，B3} {A4，B4 }假设它们都具有相同的prop1值。所以确切地说，在第一次匹配后，我不希望模

0热度

1回答

如何指定何时不发出声音？

如何指定时不火的声明中，类似如下： select a.timestamp from pattern [every a = A -> (not timer:at (0, 6:12, *, *, *) and not timer:at (0, 16:20, *, *, *))]; 我想所有指定范围时不火的声明。谢谢

0热度

1回答

ESPER CEP将在Hadoop或Spark平台上工作

我在独立系统中使用了ESPER CEP。 ESPER云是否兼容？它可以在Hadoop或Spark平台上运行谢谢

0热度

1回答

如何在运行时从Esper配置对象获取eventType

我正在运行一个使用Esper作为我的核心CEP引擎的应用程序。当我尝试获取之前在Esper运行时注册的事件类型时，我得到一个UnsupportedOperationException。 esperConfiguration.addEventType(streamName, fieldNames, fieldTypes); -------- //several lines later --

0热度

1回答

在子查询中支持esper having子句？

我写了下面的查询中的超能力： on pattern[every timer:interval(10 sec)] delete from OrderEvent as OE where OE.orderId IN (select orderId from OrderEvent group by orderId having last(orderAction) = CANCEL) 但它给我一个语法错

1热度

1回答

在几个查询中重用esper中的流

我试图使用EsperIO从数据库加载一些信息，并在具有不同条件的其他查询中使用它。要做到这一点，我用下面的代码： ConfigurationDBRef dbConfig = new ConfigurationDBRef(); dbConfig.setDriverManagerConnection("org.postgresql.Driver", "jdbc:postgr