Flink FAQ - Task 之間的數據交換

翻譯自原文:https://cwiki.apache.org/confluence/display/FLINK/Data+exchange+between+tasks Flink中的數據交換基於以下設計原則構建: 數據交換的流控是由接收方啓動的,這與原始MapReduce十分相似。 用於數據交換的數據流,即通過物理線路的實際數據傳輸,是通過IntermediateResult的概念抽象的,並且是可
相關文章
相關標籤/搜索