esper - 在Esper中强制输出

Question

我有一个非实时 Esper 配置，我在其中提供从文件读取的流。我正在尝试创建一个表达式来计算整个流的统计数据并在最后输出一个值。例如，Esper 具有强制 View 每 X 秒输出一次的语义，但是当您知道没有更多事件可提供时，是否有要求 View 或引擎“刷新”输出的语义。

Answer 1

事实证明，至少有一种方法可以做到这一点，即使用带有变量触发器的输出子句。

表达式为:

select count(*) as totalCount from events output last when OutputSummary = true

OutputSummary 变量将像这样初始化:

epConfiguration.addVariable("OutputSummary", Boolean.class, "false");

当您准备好刷新时，将变量设置为 true，如下所示:

epRuntime.setVariableValue("OutputSummary", true);
long currentTime = epService.getEPRuntime().getCurrentTime();
epRuntime.sendEvent(new CurrentTimeEvent(currentTime));

需要发送另一个时间事件来强制表达式求值。