Flink的觸發器Trigger介紹和使用

觸發器定義了window什麼時候會被求值以及什麼時候發送求值結果。觸發器能夠到了特定的時間觸發也能夠碰到特定的事件觸發。例如：觀察到事件數量符合必定條件或者觀察到了特定的事件。java 默認的觸發器將會在兩種狀況下觸發 處理時間：機器時間到達處理時間 事件時間：水位線超過了窗口的結束時間web 觸發器能夠訪問流的時間屬性以及定時器，還能夠對state狀態編程。因此觸發器和process funct

>>阅读原文<<