Flink CEP SQL有可能在跳跃窗口上运行吗

Question

我的典型用例是继续监控事件流以检测事件模式，但我希望窗口是跳转窗口。默认情况下，CEPSQL中的间隔...应该定义一个翻转窗口。是否可以为CEP模式匹配设置跳转窗口？或任何其他解决方案？

谢啦

Answer 1

如果“Flink-CEP-SQL”的意思是MATCH_RECOGNIZE，那么区间内的约束实际上不会映射到任何特定类型的窗口。您可以使用符合您需求的赛后策略。

Answer 2

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

以下是一些草图示例：

sql prettyprint-override">-- 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 ...)