240 发简信
IP属地:内蒙古
  • Resize,w 360,h 240
    Calcite CBO ③ - VolcanoPlanner 之 TopDownRuleDriver

    TopDownRuleDriver 是 cascades 论文的标准实现,我们以下面的 case 来跟踪代码: TopDownRuleDrive...

  • Resize,w 360,h 240
    Calcite CBO ② - VolcanoPlanner 之 IterativeRuleDriver

    一、IterativeRuleQueue 该算法不断的从 RuleQueue 中取出 Rule 并执行,该过程有两个退出条件: RuleQueu...

  • Resize,w 360,h 240
    Calcite CBO ① - 核心流程

    一、问题 & 目标 数据库/大数据引擎主要由三部分组成,分别是解析器、优化器和执行引擎,如下图所示: 其中,优化器在很大程度上决定了性能,其作用...

  • Resize,w 360,h 240
    Spark Join 源码剖析② - BroadcastHashJoinExec & ShuffledHashJoinExec

    一、如何选取到 broadcast join Join 具有 hint 的情况会调用 createBroadcastHashJoin(onlyL...

  • Resize,w 360,h 240
    Spark Join 源码剖析①

    一、Join 逻辑计划生成 和 Join 相关的逻辑层的优化规则主要包含以下几种: ReorderJoin EliminateOuterJoin...

  • Resize,w 360,h 240
    论文解读:Optimizing Queries Using Materialized Views: A Practical, Scalable Solution

    Paper "Optimizing Queries Using Materialized Views: A Practical, Scalabl...

  • Resize,w 360,h 240
    Flink 作业生成②:StreamGraph -> JobGraph

    由前文我们知道,StreamGraph 表示一个流任务的逻辑拓扑,可以用一个 DAG 来表示(代码实现上没有一个 DAG 结构),DAG 的顶点...

  • Resize,w 360,h 240
    Flink 作业生成①:生成 StreamGraph

    一、作业生成及提交整体流程 上图为一个 Flink 作业的提交流程,主要可以分为以下几个步骤: Client 将作业 code 生成 Strea...

  • Resize,w 360,h 240
    Calcite - 看懂 Parser.jj 中的 SqlSelect

    javacc 会根据 parser.jj 中定义的相互穿插的 Token、Java 代码来自动生成 org.apache.calcite.sql...

个人介绍
永不止步 Keep Moving