cep

0зной

1ответ

Ошибка при отправке файла конфигурации в fiware cepheus cep GE

У меня возникла проблема при использовании компонента cepheus cep Fiware. Я подготовил файл config.json, определяющий структуру входящих и конечных данных, а также операторов Esper SQL, которые должны

0зной

1ответ

категоризировать или GroupBy данных Datastream и процесс с КЭП отдельно

Предположим, у меня есть поток данных x:1, y:2 , z:3 , x:7 , y:-1, z:0, z:3 , z:2, y:3 ,x: 2 ,y:6 Как я положил x,y,z в их собственном ведре и применить мое правило КЭП на нем. x:1, x:7,x: 2 y:2, y

0зной

1ответ

SplitStream для динамического выходного ключа (Выбрать)

Это мой код. SplitStream<MonitoringEvent> splitStream = inputStream.split(new OutputSelector<MonitoringEvent>() { @Override public Iterable<String> select(MonitoringEvent me) { List<

0зной

1ответ

СЕР - шаблон не выполняется после добавления окна

// Создание окна из десяти пунктов WindowedStream<ObservationEvent,Tuple,GlobalWindow> windowStream = inputStream.keyBy("rackId").countWindow(10); // Применение функционального окна, добавляя некото

0зной

1ответ

Сиддхи логический И с внутри, неожиданно выполняет обратный вызов

Использование Siddhi CEP 3.1.2 в качестве автономной библиотеки, я использую try выяснить, как правильно запустить обработчик обратного вызова в нескольких условиях. Два события, соединенные логически

0зной

1ответ

Как выбрать 2 разных атрибута из события в Drools

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

0зной

1ответ

CEP Dashboard - Визуализация точек в галактике Geo Map

У меня есть выходной поток, который имеет lat-long точек с набором других атрибутов. Когда я вывожу тот же поток, что и гаджет таблицы, я получаю данные ниже (снимок экрана). Но когда я использую тот