Мне интересно, пробовал ли кто-нибудь здесь использовать Esper для обработки данных из облака? В частности, Amazon Simple Queuing Service. Я гуглил об этом, и мы знаем, что это возможно, но было бы неплохо узнать, пробовал ли кто-нибудь это. Еще...

Я пытаюсь отправить события в движок Esper через сокеты и столкнулся с некоторой проблемой. я настроил свойства EsperIOSocketAdapter, и когда вызывается метод EsperIOSocketAdapter.start(), он запускает новый поток демона, который будет прослушивать...

Я новичок в Esper, который представляет собой структуру обработки сложных событий Java. В настоящее время я использую следующий запрос: select min(low) as minLow,max(high) as maxHigh from Bar.win:time_batch(180 sec); Я также хочу получить...

Я хотел бы создать длительный процесс Esper , но я не уверен ни в модели потоков Esper, ни в модель, которую я должен реализовать, чтобы сделать это. Наивно я попробовал следующее: public class EsperTest { /** * @param args the command line...

Я пытаюсь отправить событие со следующим кодом, но дважды получаю его в зарегистрированном прослушивателе. Может быть, что-то не так с запросом в регистрации слушателя или я сделал какую-то другую ошибку? Спасибо за любой совет!...

Я использую Esper 5.0 и мне нужно выполнить запрос данных из реляционной базы данных. В моем случае это база данных MySQL, подключенная через JDBC. Теперь я хотел бы сформулировать EPL-запрос к данным из базы данных. Следовательно, мой запрос похож...

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

Все измерения поставлялись с отметкой времени (временем события), когда измерение было создано. Некоторые из этих измерений являются искусственными, то есть они создаются не самим устройством, а правилом CEP, работающим внутри CoT. The "normal"...

Я обнаружил потерю данных в Esper (v.7.1.0) в случае, если включен пул входящих потоков. Вот простой пример, демонстрирующий это странное поведение: Configuration config = new Configuration(); // set up concurrent processing...

Наше текущее приложение работает на Esper V5.2, но при обновлении до V8.5 возникает следующая проблема: Всего у нас 6 узлов (ВМ). При запуске серверов несколько операторов вообще не загружаются ни на одной из виртуальных машин, и несколько...

Мне нужна средняя скорость (датчик = 1) при разных настройках мощности 1-10 (датчик = 2). Я не хочу, чтобы скорости от датчика 1 включались в средний расчет, если они произошли до изменения настройки (датчик = 2). Например. power_setting=1,...