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

前面，一篇簡單講了flink的窗口及與Spark Streaming窗口之間的對比。java 對於flink的窗口操做，尤爲是基於事件時間的窗口操做，你們還要掌三個個重要的知識點：apache 窗口分配器：就是決定着流入flink的數據，該屬於哪一個窗口。bootstrap 時間戳抽取器/watermark生成器：抽取時間戳並驅動着程序正常執行。windows trigger：決定着數據啥時候落地

>>阅读原文<<