复杂事件处理流处理

ve7v8dk2  于 2021-06-21  发布在  Storm
关注(0)|答案(1)|浏览(390)

我正在努力学习esper是如何与storm协作的,我正在看esper的源代码,因为我想知道esper把数据存储在哪里(表、数组等),例如当esper接收到一个元组流并声明了一个事件类型时,esper是如何存储这个数据的(源代码);当执行查询时,数据结果如何存储等?我想在esper的源代码中找到所有这些发生的地方。任何帮助都是最受欢迎的。

4bbkushb

4bbkushb1#

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)

模式有自己的数据结构,每个数据窗口和匹配识别等也有自己的数据结构。。连接索引等也是数据结构。恐怕没有单一的代码位置,但有许多,也没有单一的数据结构,但许多不同的专业。

相关问题