Сиддхи отсутствие событий

Question

Я пытаюсь написать запрос для ситуации типа «Если вы видите значение 10, и вы не видите значение 20 в течение следующих 10 секунд, выдают предупреждение», но не смогли заставить работать синтаксис. Согласно этому запросу, эта функция была реализована более года назад. Моя попытка запроса:

define stream inStream(value int); 
            from every s1=inStream[value == 10]  
            -> not s2=inStream[value == 20] for 10 sec  
            select s2.value  
            insert into outStream

Глядя на файл грамматики в проекте Siddhi, похоже, что это должен быть правильный запрос, однако, когда я пытаюсь запустить его, я получаю «Синтаксическая ошибка в SiddhiQL, при вводе нет подходящей альтернативы». Я запускаю это с ядром siddhi 4.2.18. У меня неправильный синтаксис или у меня другая проблема?

Answer 1

Нашел решение моей проблемы на сайте от создателя шаблона отсутствия PR.Проблема была в моем синтаксисе, поток шаблона отсутствия нельзя назвать.Поэтому, изменив запрос на

define stream inStream(value int); 
        from every s1=inStream[value == 10]  
        -> not inStream[value == 20] for 10 sec  
        select s1.value  
        insert into outStream

, он заработал идеально.