Flink CEP 對超時事件的處理

今天在羣裏面有個同窗問了一個問題,一個通用場景,例如:用戶2小時不評價訂單,自動好評功能。web 這種多長時間內沒有收到第二個事件的問題,想了下覺得能夠用notFollowedBy 來解決,結果不行。 查了一下文檔, 寫了下面一個demo,記錄一下,備忘socket final StreamExecutionEnvironment env = StreamExecutionEnvironment.
相關文章
相關標籤/搜索