Flink運行時之統一的數據交換對象

統一的數據交換對象 在Flink的執行引擎中，流動的元素主要有兩種：緩衝（Buffer）和事件（Event）。Buffer主要針對用戶數據交換，而Event則用於一些特殊的控制標識。但在實現時，爲了在通訊層統一數據交換，Flink提供了數據交換對象——BufferOrEvent。它是一個既能夠表示Buffer又能夠表示Event的類。上層使用者只需調用isBuffer和isEvent方法便可判斷當

>>阅读原文<<