Flink 自定義觸發器

  trigger接口有五個方法容許trigger對不一樣的事件作出反應：ide onElement():進入窗口的每一個元素都會調用該方法。大數據 onEventTime():事件時間timer觸發的時候被調用。this onProcessingTime():處理時間timer觸發的時候會被調用。對象 onMerge():有狀態的觸發器相關，並在它們相應的窗口合併時合併兩個觸發器的狀態，例如使用

>>阅读原文<<