Esper

Question

假设我有 CallPOPDWH 事件。该事件有 4 列。类型列、名称列、检测时间戳列和属性列。 Esper 产生以下 3 个元组：

[Event, CallPOPDWH, 1456938481000, {call_start_date=7355448481000, calling_number=+3859121JMOYL, call_direction=I}]  
[Event, CallPOPDWH, 1456938481000, {call_start_date=5464538486000, calling_number=+3859121JMOYL, call_direction=I}]
[Event, CallPOPDWH, 1456938481000, {call_start_date=1456345351000, calling_number=+3859121JMOYL, call_direction=I}]

我想执行一个查询，该查询将收集呼叫号码和检测时间戳相同的所有不同 call_start_date 值。

例如：

[Event, NewEvent, 1456938481000, {call_start_date=[7355448481000, 5464538486000, 1456345351000], calling_number=+3859121JMOYL, call_direction=I}]

我已经阅读了 Esper 的文档，虽然它说您可以创建一个模式来表示 newEvent，您可以在其中将属性声明为数组，但我还没有找到一个有效的示例。

我不知道我需要哪种查询 need.Do 我需要模式查询或 select 带有特定属性子查询的查询？任何建议都将不胜感激。

Answer 1

select window(call_start_date).distinctOf() from CallPOPDWH#keepall group by calling_number, detectionTimestamp

几点注意事项

用于记住所有值的#keepall 可以是时间 window 或其他
添加"output last every X seconds"例如当不需要连续输出时

Esper - 查询结果的数组表示

Esper - Array Representation of query results

sql

arrays

complex-event-processing