复杂事件处理流处理
问题描述:
我想了解Esper如何与Storm合作。我看看Esper的源代码,因为我想知道Esper(表,数组等)存储的数据的位置。例如当esper接收到一串元组并且声明了一个事件类型时,这个数据是如何被Esper存储的(源代码);当执行一个查询时数据结果如何存储等等?我想在Esper的源代码中找到所有这些发生的地方code.Any帮助是最受欢迎的。复杂事件处理流处理
答
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)
模式有自己的数据结构,所以做每一个数据窗口和匹配,识别等指标的联接和如也的数据结构。恐怕没有单一的代码位置,但很多,没有单一的数据结构,但有许多不同的专业代码。