Flink批處理優化器之成本估算

成本估算 在基於成本的優化器中，成本估算很是重要，它直接影響着候選計劃的生成。在Flink中成本估算依賴於每一個不一樣的運算符所提供的本身的「預算」，本篇咱們將分析什麼是成本、運算符如何提供本身的預算以及如何基於預算估算成本。java 什麼是成本 Flink以類Costs來定義成本，它封裝了一些成本估算的因素同時提供了一些針對成本對象的計算方法（加、減、乘、除）以及對這些因素未知值的認定與校驗。w

>>阅读原文<<