эспер контролирует количество событий

Я использовал esper для объединения потоков следующим образом:
введите здесь описание изображения
Теперь рассмотрим сценарий:
1. Две сделки вошли в систему
2. Цена пришла

В этом сценарии Поток группировки будет генерировать два вывода, по одному для каждой сделки. И это также вызовет два события из окончательного вывода. При увеличении количества событий количество выходных событий также будет увеличиваться.
Теперь, если сделка с
Id - 03
Символ - GOOG
Количество - 300

введен в систему, он также вызовет 3 новых события, поскольку %ageMV также изменяется для каждого идентификатора. Поскольку количество событий увеличивается, становится трудно обрабатывать пользовательский интерфейс.

Итак, мой вопрос:
Есть ли какой-либо стандартный способ сделать это?


person Chaturvedi Dewashish    schedule 16.11.2012    source источник


Ответы (1)


Вам нужно будет изучить однонаправленные соединения и подзапросы.

person user650839    schedule 16.11.2012
comment
Я уже использовал однонаправленные соединения в операторах GROUPING и FINAL OUTPUT. Позвольте мне уточнить мой вопрос: любое изменение в OrderFeed или PriceFeed приведет к срабатыванию всех строк данных из потоков FinalOutPut, поскольку будет изменен один из столбцов (% ageMV). Таким образом, набор из 10000 строк будет инициирован для каждого события либо из OrderFeed, либо из PriceFeed. - person Chaturvedi Dewashish; 16.11.2012