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

1、CEPide       一個或多個由簡單事件構成的事件流經過必定的規則匹配，而後輸出用戶想獲得的數據，知足規則的復瑣事件。測試 CEP支持在流上進行模式匹配，根據模式的條件不一樣，分爲連續的條件或不連續的條件；模式的條件容許有時間的限制，當在條件範圍內沒有達到知足的條件時，會致使模式匹配超時。scala 、日誌 CEP就至關於在流上對event進行模式匹配。好比 連續兩條登陸失敗日誌不超過2

>>阅读原文<<