esper

0热度

1回答

我要处理使用艾斯波以下JSON消息： { "firstname":"John", "lastname":"Do", "address":[{"street":"Maplestreet","number":100,"city":"New York"}] } 什么是声明的事件类型模式的正确方法是什么？有人可以帮我构建正确的EPL：create schema();声明

0热度

1回答

EPStatmentObject模型不工作？

我试图通过编译使用compileEPL（）方法来修改epl，并添加更多的例如where子句，但我很难得到它的工作。比方说这是我的EPL： select * from event where A = 1 ，我想使用AND 再添加一个WHERE条件和我编译使用compileEPL（）英超 model.getWhereClause().getChildren().add(Expressions.a

0热度

1回答

Esper。无法在侦听器中接收删除事件

在Esper中使用时间窗口时，窗口中的旧事件或已删除事件将作为输出发送到附加到该语句的UpdateListener。这是根据该文件应该发生的事情。但是当我执行下面的代码时，即使一个新的滑动窗口启动，它在oldEvents中也没有任何事件。它甚至发生在长度窗口。 EPStatement statement1 = epAdmin.createEPL("select current_timestamp,

0热度

1回答

艾斯波访问阵列事件propertie

我想用艾斯波处理以下JSON消息： { "firstname":"John", "lastname":"Do", "address":[{"street":"Maplestreet","number":100,"city":"New York"}] } 当架构的样子： create schema Address (street string, number in

0热度

1回答

调用的方法只能运行一次

我有一个在查询中调用的方法。然而，它只运行一次，但假设我发送了10个事件，监听器输出两个空事件。 select method() from Event.win:length_batch(5) 来自监听器的结果：这是正确的，因为方法dosent返回任何内容，但该方法只在触发两次时触发一次。 {method()=null} {method()=null} 有谁知道为什么吗？我想在每次窗口填满

1热度

1回答

Invoke方法，一旦所有包含事件

我如何可以调用的方法类似 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回答

复杂事件处理流处理

我想了解Esper如何与Storm合作。我看看Esper的源代码，因为我想知道Esper（表，数组等）存储的数据的位置。例如当esper接收到一串元组并且声明了一个事件类型时，这个数据是如何被Esper存储的（源代码）;当执行一个查询时数据结果如何存储等等？我想在Esper的源代码中找到所有这些发生的地方code.Any帮助是最受欢迎的。

0热度

1回答

艾斯波输出解释

考虑下列事件流和上下文的定义： create schema EventCreated( source String, type String, time String, value Integer ); create context Trip context bySource partition by source from Eve

0热度

1回答

如何在espertech中获取触发事件的列表CEP

我已经在我的项目中实现了espertech CEP，并且一切都很好，但是我想显示所有触发事件的列表。 espertech是否允许这样做？

0热度

1回答

带参数的Esper计数

我想知道是否可以使用“count”函数或等同函数但指定了参数，只计算特定结果。所以我想这样做： select ... "nbAccel", count(type='c8y_HarshBehavior' and behaviorType = "ACCELERATION") "nbBraking", count(type='c8y_HarshBehavior' and