Flink-CEP之帶版本的共享緩衝區

帶版本的共享緩衝區 當股票模式以一個事件流做爲輸入時，狀態轉換將會做用於事件流從而引發事件的狀態變化。結合窗口對參與匹配的事件的限制以及模式中結合事件上下文（狀態）的過濾條件，同一事件流隨着時間的流動或者屢次運行都會產生多種不一樣的匹配結果。在此咱們爲示例模式構建了一個事件流以及其可能產生的三種匹配結果，以下圖：java 在事件e6到達後，會產生兩個結果：R1和R2，而結果R3將會在e8到來以後匹

>>阅读原文<<