Обработка сложных событий Обработка потока

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) 

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