在 Esper CEP 模式中定义时间 window
Defining time window in Esper CEP pattern
我有一个包含时间戳事件的 CSV 文件，我想在 Esper 模式中集成外部时间戳。
我知道如何使用windowext_timed。
例如，这有效：
select * from stream.win:_ext_timed(timestamps, 5 sec).
但我不知道如何在模式中使用外部时间。
例如，在以下查询中使用了引擎内部时间。我想在 within 守卫中使用外部时间。
select * from pattern [ a=stream -> stream where timer:within(5 sec) ]
提前时间的API在[1]中。
EsperIO CSV 适配器所做的事情与您计划做的事情几乎相同，您可以查看其源代码。它将使用相同的 API [1].
我有一个包含时间戳事件的 CSV 文件，我想在 Esper 模式中集成外部时间戳。 我知道如何使用windowext_timed。 例如，这有效：
select * from stream.win:_ext_timed(timestamps, 5 sec).
但我不知道如何在模式中使用外部时间。 例如，在以下查询中使用了引擎内部时间。我想在 within 守卫中使用外部时间。
select * from pattern [ a=stream -> stream where timer:within(5 sec) ]
提前时间的API在[1]中。 EsperIO CSV 适配器所做的事情与您计划做的事情几乎相同，您可以查看其源代码。它将使用相同的 API [1].