Esper是EsperTech Inc.开发的CEP（复杂事件处理）和ESP（事件流处理）应用程序的轻量级开源库。
我们正在esper中创建一个每小时的上下文，并将@hint与输出速率限制器一起使用。但是在某些事件中，我们仍然会耗尽内存。 XMX -12 G在某些情况下，如果压缩不好，...
我对这项技术还很陌生，我需要能够检测到准确顺序发生的事件。例如：a-> b-> c根据这些事件输出事件a-> b-> d->…-> c将...
下面的实际使用情况，已经已实现由我们的公司：我们已经建立了应用与REST API围绕超能力者的Java API包装。用户可以定义它的地图模式和查询......
如何从一个KafkaSpout一次发送多个（不同的）元组到螺栓？
我是Apache Storm的新手。我正在尝试使用Apache Kafka，Storm和ESPER CEP引擎开发实时流处理系统。为此，我有一个将发射流的KafkaSpout ......
我有一个时间窗口和一个变量，它是时间窗口的参数。 CREATE VARIABLE int expireSecs = 10; SELECT * FROM Event＃time（expireSecs sec）;在我调用的代码中设置expireSecs ...
为什么length_batch在ESPER CEP查询中多次调用我的单行函数？
我正在使用ESPER CEP引擎处理实时的天气数据流。我有一个用例，我正在使用length_batch进行一批流，即AvgWeatherEvent.win:length_batch(5）...
如何使用ESPER性能套件来测量具有单行函数的查询的延迟和吞吐量
我编写了一些在查询中使用单行函数的ESPER CEP查询。现在，我想使用ESPER性能套件测量查询的延迟和吞吐量。所以我要加我...
如何在esper上对窗口进行分组（我希望esper能够为每个组创建窗口。）
我想esper每个组创建窗口。从SampleEvent.win:length(5）组中选择名称，sum（val）按名称工作它像这样工作我希望它像这样工作我可以像这样实现...
我们假设我有CallPOPDWH事件。该活动有4列。类型列，名称列，检测时间戳列和属性列。 Esper产生以下3个元组：[...