复杂事件处理流处理

Question

我想了解Esper如何与Storm合作。我看看Esper的源代码，因为我想知道Esper（表，数组等）存储的数据的位置。例如当esper接收到一串元组并且声明了一个事件类型时，这个数据是如何被Esper存储的（源代码）;当执行一个查询时数据结果如何存储等等？我想在Esper的源代码中找到所有这些发生的地方code.Any帮助是最受欢迎的。

Answer 1

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

这店什么：

select * from MyEvent 

此只存储一个长型计数：

select count(*) from MyEvent 

它保存了一个数和总：

select avg(field) from MyEvent 

它保存每一个计数groupfield：

select count(*) from MyEvent group by groupfield 

此存储最后5个事件：

select * from MyEvent.win:length(5) 

模式有自己的数据结构，所以做每一个数据窗口和匹配，识别等指标的联接和如也的数据结构。恐怕没有单一的代码位置，但很多，没有单一的数据结构，但有许多不同的专业代码。