95-874-040-源码-批处理-Flink批处理优化器值成本估算

Posted 九师兄

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了95-874-040-源码-批处理-Flink批处理优化器值成本估算相关的知识,希望对你有一定的参考价值。

1.视图

3.成本估算

​ 在基于成本的优化器中,成本估算非常重要,它直接影响着候选计划的生成。在Flink中成本估算依赖于每个不同的运算符所提供的自己的“预算”,本篇我们将分析什么是成本、运算符如何提供自己的预算以及如何基于预算估算成本。

4. 什么是成本

​ Flink以类Costs来定义成本,它封装了一些成本估算的因素同时提供了一些针对成本对象的计算方法(加、减、乘、除)以及对这些因素未知值的认定与校验。

“cost”一词也有译作:开销、代价,将其视为同义即可。

以上是关于95-874-040-源码-批处理-Flink批处理优化器值成本估算的主要内容,如果未能解决你的问题,请参考以下文章

FlinkFlink源码分析——批处理模式JobGraph的创建

FlinkFlink 批处理模式Map端数据聚合 NormalizedKeySorter

Apache Beam 在批处理方面比 Spark/Flink 有啥好处?

是否可以在流式 flink 作业中创建批处理 flink 作业?

如何在 Flink 中使用本地执行模式执行批处理 sql?

使用Flink批处理完成数据比对(对账)三