我正在努力学习esper是如何与storm协作的,我正在看esper的源代码,因为我想知道esper把数据存储在哪里(表、数组等),例如当esper接收到一个元组流并声明了一个事件类型时,esper是如何存储这个数据的(源代码);当执行查询时,数据结果如何存储等?我想在esper的源代码中找到所有这些发生的地方。任何帮助都是最受欢迎的。
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)
模式有自己的数据结构,每个数据窗口和匹配识别等也有自己的数据结构。。连接索引等也是数据结构。恐怕没有单一的代码位置,但有许多,也没有单一的数据结构,但许多不同的专业。
1条答案
按热度按时间4bbkushb1#
esper的数据结构反映了epl语句。
这不存储任何内容:
这只存储长类型计数:
这将存储计数和总数:
这将存储每个groupfield的计数:
它存储最后5个事件:
模式有自己的数据结构,每个数据窗口和匹配识别等也有自己的数据结构。。连接索引等也是数据结构。恐怕没有单一的代码位置,但有许多,也没有单一的数据结构,但许多不同的专业。