我EPL很简单： select symbol, sum(price) from MarketData(symbol!='').win:time(5.5 sec) group by symbol
监听器： update(EventBean[] newEvents, EventBean[] oldEvents) {
System.out.println(newEvents.length)
我正在尝试批处理这样的通知事件，并且我正在通过一个通知事件获取一个Notifications事件。谁能帮我？ 提前提醒。 相关声明 INSERT INTO Notification SELECT d.id as id,a.stationId as stationId,d.firebaseToken as firebaseToken, d.position as devicePos,a.locati
我最近一直在使用Esper，并且有一个我在文档中遗漏的功能，但它可能存在。 我想存储一些事件，直到没有人弹出15秒，当它发生时释放他们。 一个查询正是这么做的，它是： select rstream * from MyEvent.win:time_accum(15 sec)
我可以在MyEvent添加条件像 select rstream * from MyEvent where status =
（1）我需要将Esper数据库适配器连接到我的项目。使用this 为指导IM，但我不知道在哪里可以找到的配置文件，因为即时得到这个错误：Cannot locate configuration information for database 'db1' 这是我 public class Esper {
public void iniciar() {
EPServiceProvide