Я использовал esper для объединения потоков следующим образом:
Теперь рассмотрим сценарий:
1. Две сделки вошли в систему
2. Цена пришла
В этом сценарии Поток группировки будет генерировать два вывода, по одному для каждой сделки. И это также вызовет два события из окончательного вывода. При увеличении количества событий количество выходных событий также будет увеличиваться.
Теперь, если сделка с
Id - 03
Символ - GOOG
Количество - 300
введен в систему, он также вызовет 3 новых события, поскольку %ageMV также изменяется для каждого идентификатора. Поскольку количество событий увеличивается, становится трудно обрабатывать пользовательский интерфейс.
Итак, мой вопрос:
Есть ли какой-либо стандартный способ сделать это?
эспер контролирует количество событий
Ответы (1)
Вам нужно будет изучить однонаправленные соединения и подзапросы.
person
user650839
schedule
16.11.2012
Я уже использовал однонаправленные соединения в операторах GROUPING и FINAL OUTPUT. Позвольте мне уточнить мой вопрос: любое изменение в OrderFeed или PriceFeed приведет к срабатыванию всех строк данных из потоков FinalOutPut, поскольку будет изменен один из столбцов (% ageMV). Таким образом, набор из 10000 строк будет инициирован для каждого события либо из OrderFeed, либо из PriceFeed.
- person Chaturvedi Dewashish; 16.11.2012