在Esper中强制输出

Question

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

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));

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

Answer 2

当输出需要每 60 秒时，则表达式将为：

select emplyee_id from employees output snapshot every 60 sec

当输出需要每 10000 个事件时，表达式将为：

select emplyee_id from employees output snapshot every 10000 events