Flink中的Broadcast廣播變量

在Flink中，同一個算子可能存在若干個不一樣的並行實例，計算過程可能不在同一個Slot中進行，不一樣算子之間更是如此，所以不一樣算子的計算數據之間不能像Java數組之間同樣互相訪問，而廣播變量Broadcast即是解決這種狀況的。以下代碼所示：javascript val env = ExecutionEnvironment.getExecutionEnvironment val ds1

>>阅读原文<<