Комплексная обработка событий - потоковая обработка

Question

Я пытаюсь понять, как Esper сотрудничает с Storm. Я смотрю на исходный код Esper, потому что хочу узнать, где Esper хранит данные (таблицы, массивы и т. Д.). Например, когда esper получает поток кортежей и тип события объявляется, как эти данные хранятся в Esper(исходный код); когда выполняется запрос, как хранятся результаты данных и т. д. Я хочу выяснить, где все это происходит в исходном коде Esper. Любая помощь приветствуется.

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)

Шаблоны имеют свои собственные структуры данных, так же как каждое окно данных и распознавание совпадений и т. Д. Индексы для объединений и тому подобное также являются структурами данных. Я боюсь, что нет единого местоположения кода, но много и нет единой структуры данных, но много разных специализированных.