Как я могу установить непрерывность между шаблонами в Flink CEP SQL?
Мы знаем, что в Flink CEP Java такие API, как next(), followedBy () и sequence (), могут использоваться для установки непрерывности между различными шаблонами. Однако в CEP SQL, поскольку синтаксис относительно прост, трудно четко описать преемственность между шаблонами.
Мой вопрос: если определенные шаблоны являются ШАБЛОНОМ (a b + c), все ли события соответствуют шаблонам a, b и c строго непрерывно? Я имею в виду, является ли ШАБЛОН (a b + c) в CEP SQL эквивалентом a.next (b) .oneOrMore(). Sequence (). Next (c) в CEP Java?
Например, для ШАБЛОНА (a b + c), если поток входных событий - {abbbc axbxbc}, я хочу выводить только {abbbc}, потому что {axbxbc} содержит несовпадающее событие x, которое необходимо исключить.