flink自定義trigger-實現窗口隨意輸出

前面，一篇簡單講了flink的窗口及與Spark Streaming窗口之間的對比。 對於flink的窗口操作，尤其是基於事件時間的窗口操作，大家還要掌三個個重要的知識點： 窗口分配器：就是決定着流入flink的數據，該屬於哪個窗口。 時間戳抽取器/watermark生成器：抽取時間戳並驅動着程序正常執行。 trigger：決定着數據啥時候落地。 flink有很多內置的觸發器，對於基於事件時間的窗

>>阅读原文<<