特牛网址导航

十三 Flink CEP_scala loginevent("user_1", "fail", "0.0.0.0", 1000-CSDN博客

网友收藏
文章浏览阅读111次。文章目录1 概念2 使用2.1 pom文件2.2 使用2.3 Pattern API3 案例3.1 检测连续三次登录失败的事件3.2 订单超时检测1 概念一个或多个由简单事件构成的事件流通过一定的规则匹配,然后输出用户想得到的数据,满足规则的复杂事件。特征:• 目标:从有序的简单事件流中发现一些高阶特征• 输入:一个或多个由简单事件构成的事件流• 处理:识别简单事件之间的内在联系,多个符合一定规则的简单事件构成复杂事件• 输出:满足规则的复杂事件在这里插入图片描述2 使用2.1 pom_scala loginevent("user_1", "fail", "0.0.0.0", 1000l),