如何使用Apache Flink分析事件序列以觸發操作？

Question

我想根據分析實時與Apache弗林克事件流和觸發動作：

• 事件窗口，在特定事件發生（「如果事件A和事件B發生在30秒內 - >觸發動作「）
• 事件序列，其中特定事件發生（」如果事件B和事件後事件A發生ç事件B發生後 - >觸發動作「）的兩個

我知道

組合flink有能力獲勝通過stream.windowAll(...)下降，但我不確定如何反映事件序列。

怎樣才能實現這樣的事件序列檢測？

Answer 1

FlinkCEP（https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/libs/cep.html）是一個CEP（複雜事件處理）庫，能夠以更抽象的方式處理事件流，並且（除其他外）涵蓋您描述的場景。