Flink CEP SQL是否可以在跳跃窗口上运行

Question

我的典型用例是不断监视事件流以检测事件模式，但我希望窗口是一个跳跃窗口。默认情况下，CEP SQL中的interval ...应该定义一个翻滚窗口。是否可以有一个用于CEP模式匹配的跳变窗口？或任何其他解决方案？

感谢

Answer 1

可以在Flink SQL中嵌套基于时间的查询。因此，您可以在以前执行过窗口操作的视图上定义MATCH_RECOGNIZE子句。

以下是一些草图示例：

-- get the rowtime from the window operation
CREATE TEMPORARY VIEW my_view AS
SELECT HOP_ROWTIME(rowtime, INTERVAL '1' SECOND, INTERVAL '2' SECOND) AS windowedRowtime, ...
FROM my_table
GROUP BY HOP(rowtime, INTERVAL '1' SECOND, INTERVAL '2' SECOND);
-- use the new rowtime for MATCH_RECOGNIZE
SELECT * FROM my_view MATCH_RECOGNIZE(ORDER BY windowedRowtime ...)

Answer 2

如果通过"Flink CEP SQL"；如果你的意思是MATCH_RECOGNIZE，那么WITHIN INTERVAL约束并没有真正映射到任何特定类型的窗口上。您可以使用任何符合您需求的AFTER MATCH策略。