全部面试刷题微服务数据库消息队列搜索引擎大数据运维 go语言人工智能

如何在Flink CEP中处理时间约束？

提问者：帅平问题分类：面试刷题

Flink面试题 Flink

发布于：3周前 (05-19) IP属地：

1 个回答

缝完心脏、一个人活

主要通过时间窗口（within）和事件时间语义来管理事件序列的有效性。举几个例子
全局时间窗口（within）

Pattern.<Event>begin("start")
    .followedBy("end")
    .within(Time.minutes(10)); // 整个模式必须在10分钟内完成

发布于：3周前 (05-19) IP属地：

我来回答