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

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

в настоящее время мы тестируем сиддхи wso2 cep. нам нужно иметь возможность перезапустить серверный процесс wso2 без потери данных, которые были накоплены в окне (например, временном окне). Есть ли способ сделать временные окна постоянными,...

Каков синтаксис для записи выражения временного окна Siddhi только для текущего дня. Я хочу рассчитать количество групп событий по любому атрибуту события только на сегодняшнюю дату. Я планирую использовать #window.time(86400000), но предполагаю,...

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

Я работаю над финальной версией 6.2 drools fusion и хочу активировать правила в случае нового события в потоковом режиме. Но правила не стреляют сами по себе. Содержимое файла моих правил выглядит следующим образом: //created on: May 8, 2015...

Я пробую WSO2 CEP для нашего нового требования. В настоящее время я написал запрос, чтобы найти события тайм-аута. из InputStream#window.time(5 минут) выберите * вставить в TimeoutRequest для событий с истекшим сроком действия. Но мое...

Я пытаюсь настроить WSO2 CEP для хранения событий в таблице базы данных. Я создал Event Stream/Receiver, Я хотел бы опубликовать поток во внешней базе данных, используя источник данных. я получаю следующую ошибку, когда пытаюсь создать...

У меня есть веб-сервисы (REST). Я хочу вызывать WS каждый раз, когда на мой поток приходит событие. Мне нужно создать расширение Siddhi и вызвать веб-сервис из java? Если мне нужна java для вызова веб-службы, должен ли я расширить «Агрегатную...

У меня есть панель инструментов, отображающая информацию из Stream. Я хочу использовать эту панель инструментов в другом приложении Java. Есть антецеденты?, это возможно? Спасибо за ваши Коментарии.

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

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

Я использую Siddhi 5.1. Я использую Siddhi Manager для создания и запуска приложения. Я хочу обновить запущенное приложение новым приложением. В настоящее время я останавливаю работающее приложение, создаю новую среду выполнения и запускаю новое...

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

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