esper - ESPER 中的文件结束检测

Question

我正在使用 ESPER 从 CSV 文件中读取事件。读取 CSV 文件完成后，如何使查询输出一些内容。

例如，我想每 30 分钟或在文件末尾输出一次

SELECT id FROM stream output every 30 min or [ EOF reached ]

提前致谢 问候

Answer 1

当 CSV 文件完成并且代码可以将 EOF 事件发送到引擎时，“adapter.start()”完成。您可以声明一个在该 EOF 事件上结束的上下文，并且有一个“每 30 分钟输出一次，并在终止时”选项。