复杂事件处理-流处理

Question

我正在尝试了解Esper如何与Storm.I协作。我正在查看esper的源代码，因为我想找出Esper (表、数组等)存储数据的位置。.For示例当Esper接收到一个元组流并声明了一个事件类型时，Esper如何存储这些数据(源代码)；当执行一个查询时，数据结果是如何存储的等等?我想在Esper的源代码code.Any帮助中找到所有这些发生的位置。

Answer 1

Esper的数据结构反映了EPL语句。

这不存储任何内容：

select * from MyEvent

这只存储一个长类型的计数：

select count(*) from MyEvent

这存储了一个计数和总数：

select avg(field) from MyEvent

这将为每个组字段存储一个计数：

select count(*) from MyEvent group by groupfield

这将存储最后5个事件：

select * from MyEvent.win:length(5)

模式有自己的数据结构，每个数据窗口和匹配识别等也是如此。joins等的索引也是数据结构。我担心没有单一的代码位置，但有许多，没有单一的数据结构，但有许多不同的专业结构。