Flink的CEP使用流程+使用案例

1、CEPide       一个或多个由简单事件构成的事件流经过必定的规则匹配，而后输出用户想获得的数据，知足规则的复琐事件。测试 CEP支持在流上进行模式匹配，根据模式的条件不一样，分为连续的条件或不连续的条件；模式的条件容许有时间的限制，当在条件范围内没有达到知足的条件时，会致使模式匹配超时。scala 、日志 CEP就至关于在流上对event进行模式匹配。好比 连续两条登陆失败日志不超过2

>>阅读原文<<