Flink運行時之生產端結果分區

生產端結果分區 生產者結果分區是生產端任務所產生的結果。以一個簡單的MapReduce程序爲例，從靜態的角度來看，生產端的算子（Map）跟消費端的算子（Reduce），二者之間交換數據經過中間結果集（IntermediateResult）。形以下圖：java 而IntermediateResult只是在靜態表述時的一種概念，在運行時，算子會被分佈式部署、執行，咱們假設兩個算子的並行度都爲2，那麼對

>>阅读原文<<