Flink 自定義Trigger實戰代碼，結合State來使用

簡單說明： 好比window大小爲20秒，在進入window的時候 有一個valueState在統計數據數量，數量大於等於2的時候直接觸發這個窗口，若是在20秒事件窗口內只有一條數據進入 那麼正常等window事件到了 就會觸發這一條數據了 。 apache package appOperator; import com.alibaba.fastjson.JSONObject; import o

>>阅读原文<<