【源碼解析】Flink 滑動窗口數據分配到多個窗口

之前一直用翻滾窗口，每條數據都只屬於一個窗口，所有不需要考慮數據需要在多個窗口存的事情。 剛好有個需求，要用到滑動窗口，來翻翻 flink 在滑動窗口中，數據是怎麼分配到多個窗口的 一段簡單的測試代碼： val input = env.addSource(kafkaSource) val stream = input .map(node => { Event(n

>>阅读原文<<