Вопросы по теме 'esper'

Как с помощью Esper выполнить динамическую фильтрацию событий?
Я новичок в использовании механизма потока событий Esper в Java. Сценарий заключается в том, что события поступают как POJO. У них есть поле, которое я хочу отфильтровать. Отфильтрованные значения будут меняться со временем. Я бы предпочел не...
2479 просмотров
schedule 14.04.2022

Как заказать событие в нескольких потоках в одном Epser Engine
В настоящее время я использую обработчик событий Esper . Ситуация следующая: Один сервер получает несколько сообщений от клиентов, эти сообщения вставляются в поток. В настоящее время существует два типа потоков, называемых str1, str2 , каждый...
252 просмотров
schedule 16.12.2023

Эспер: найти самое раннее событие во времени после наступления триггерного события.
Мой поток событий обычно содержит событие открытия, за которым следует событие закрытия. Назовем их O и C соответственно. Однако есть две особенности: За O может следовать один или несколько O до прибытия C C может полностью...
272 просмотров
schedule 07.06.2023

Эпизоды генерации эсперов
Я хотел бы использовать Esper для генерации эпизодов событий. Я пытаюсь обнаружить изменения в движении робота в течение каждого периода времени, и мне было интересно, какой будет лучший способ реализации. Правила генерации эпизодов из событий...
94 просмотров
schedule 26.11.2023

Эсперское выражение не работает
Сейчас я изучаю выражения на языке эспер и совсем запутался. У меня есть простой пример, имитирующий датчик влажности, который передает числа каждые несколько секунд. С моим чтением я сделал довольно сложный пример: select avg(value),...
112 просмотров
schedule 03.01.2024

Обработка сложных событий с помощью Esper и Twitter дает twitter4j.internal.org.json.JSONException: текст JSONArray должен начинаться с '['
Привет, я пробую пример с http://www.mulesoft.org/connectors/es . .. Но это дает следующее исключение. Вызванный: twitter4j.internal.org.json.JSONException: текст JSONArray должен начинаться с '[' в 1 [символ 2, строка 1] в...
592 просмотров
schedule 10.12.2022

Ассоциация Esper EventBean и EPStatement
Можно ли каким-либо образом связать вывод объекта Esper EventBean с исходным EPStatement, который произвел результат с использованием Java? У меня определено несколько EPStatements, использующих аннотацию @Name, но я заметил, что это значение...
230 просмотров
schedule 14.07.2022

Эспер Повторные запросы по требованию
Читая документацию Esper, я хотел бы использовать запросы по требованию. Однако можно ли создать запрос по запросу, который выполняется в течение определенного периода времени? Поддерживает ли Esper это или мне нужно написать свою собственную...
296 просмотров
schedule 10.02.2024

Эспер @Name не подхватывается Java
Я создал файл epl, содержащий аннотацию @Name. Когда я пытаюсь выполнить модульное тестирование кода, он выдает ошибку о том, что не может найти оператор @Name. Так что в настоящее время у меня есть /********************** *Делать что-то...
98 просмотров
schedule 03.07.2022

Эспер Как присоединиться к столу
Я уверен, что это утверждение работает в Esper: /* query from table TableA when receive event PriceEvent */ ON PriceEvent p SELECT a.SymbolA, p.price FROM TableA a WHERE a.Symbol = p.Symbol Но это утверждение выдает ошибку: /* join table...
1057 просмотров
schedule 30.01.2023

Эспер - правило срабатывает дважды
Мне нужна помощь по движку CEP Esper: я написал следующее заявление: SELECT clientID FROM MovementEvent.win:time_batch(5 sec) GROUP BY clientID А затем я отправил в движок MovementEvent. через 5 секунд срабатывает подписчик - ок. Но еще...
88 просмотров
schedule 23.12.2022

Обращение к именованным глобальным выражениям внутри фильтра событий с использованием EPStatementObjectModel (Esper)
Я знаю, что вы можете создавать глобальные выражения с помощью объектной модели оператора Эспера, используя CreateExpressionClause и ExpressionDeclaration , но я не совсем уверен, как вы можете ссылаться на их псевдонимы при построении...
157 просмотров
schedule 22.03.2022

как получить старый ивент в esper?
Я делаю программу на основе окна длины в Esper. Но когда окно заполнено, предыдущее событие должно стать старым событием. Когда я пытаюсь напечатать это старое событие в updateListener, я каждый раз получаю нулевое значение. EPServiceProvider sp =...
231 просмотров
schedule 21.12.2023

Эспер считает повторяющиеся события по образцу
У меня есть последовательность событий, которая выглядит следующим образом: Событие А запускает последовательность Произошло несколько событий B Событие C останавливает последовательность Я сделал это с шаблоном [каждый A -> (B до C)],...
674 просмотров
schedule 23.01.2023

Эспер: StackOverflowError при перемещении паттернов в/из изолированного состояния в эспер
Я хотел инициализировать/обновить состояние шаблона из исторических данных и в некоторых случаях часто получал StackOverflowError. Я написал простой пример для демонстрации: public class Main { EsperPatternStackOverflow.zip public static void...
101 просмотров
schedule 16.10.2023

Эспер - обнаружить событие после отсутствия
Я узнал, что можно определить отсутствие события, например: выбрать * из шаблона [каждый EventX -> (таймер: интервал (10 секунд), а не EventX)], но также возможно ли обнаружить наличие события после его отсутствия? Возможно, используя априор? И...
265 просмотров
schedule 06.12.2023

Простой подзапрос в Esper
Я хочу иметь возможность вкладывать запросы, выраженные в EPL Esper. Предположим, я хочу обнаружить этот шаблон: A -> (B -> C) . ( A , B и C — типы событий, -> — оператор последовательности EPL.) Вот запрос, представляющий B...
440 просмотров
schedule 15.08.2023

Как передать сбор событий в выписке Esper EPL
Я создал новую функцию с одной строкой, которая принимает набор событий в качестве входного параметра. Я могу обрабатывать отдельные параметры события в операторе EPL, но не могу узнать, как передать набор событий в качестве параметра в операторе...
187 просмотров
schedule 17.08.2023

Использование epls для вычислений с несколькими зависимыми уровнями
Я новичок в Эспере . Мне нужна помощь в поддержании потока EPL . У меня есть класс java EsperTest.java , этот класс отправляет данные в EPL для расчета каждые 10 секунд. В EPL у меня есть 4 уровня Compression . Например. СжатиеA,...
42 просмотров
schedule 17.03.2024

Таймер шаблона эспера: интервал () не работает
У меня есть этот основной код POC. Я вижу, что события публикуются, но не получают никаких предупреждений в слушателях. В приведенном ниже коде ни один из операторов pattern1 или pattern2 не получает предупреждения. SetInternalTimerEnabled в...
417 просмотров
schedule 30.06.2022