IP屬地：云南
-
Calcite CBO ③ - VolcanoPlanner 之 TopDownRuleDriverTopDownRuleDriver 是 cascades 論文的標(biāo)準(zhǔn)實現(xiàn)，我們以下面的 case 來跟蹤代碼： TopDownRuleDrive...
-
Calcite CBO ② - VolcanoPlanner 之 IterativeRuleDriver一、IterativeRuleQueue 該算法不斷的從 RuleQueue 中取出 Rule 并執(zhí)行，該過程有兩個退出條件： RuleQueu...
-
Calcite CBO ① - 核心流程一、問題 & 目標(biāo) 數(shù)據(jù)庫/大數(shù)據(jù)引擎主要由三部分組成，分別是解析器、優(yōu)化器和執(zhí)行引擎，如下圖所示： 其中，優(yōu)化器在很大程度上決定了性能，其作用...
-
Spark Join 源碼剖析② - BroadcastHashJoinExec & ShuffledHashJoinExec一、如何選取到 broadcast join Join 具有 hint 的情況會調(diào)用 createBroadcastHashJoin(onlyL...
-
Spark Join 源碼剖析①一、Join 邏輯計劃生成 和 Join 相關(guān)的邏輯層的優(yōu)化規(guī)則主要包含以下幾種： ReorderJoin EliminateOuterJoin...
-
論文解讀：Optimizing Queries Using Materialized Views: A Practical, Scalable SolutionPaper "Optimizing Queries Using Materialized Views: A Practical, Scalabl...
-
Flink 作業(yè)生成②：StreamGraph -> JobGraph由前文我們知道，StreamGraph 表示一個流任務(wù)的邏輯拓?fù)洌梢杂靡粋€ DAG 來表示（代碼實現(xiàn)上沒有一個 DAG 結(jié)構(gòu)），DAG 的頂點...
-
Flink 作業(yè)生成①：生成 StreamGraph一、作業(yè)生成及提交整體流程 上圖為一個 Flink 作業(yè)的提交流程，主要可以分為以下幾個步驟： Client 將作業(yè) code 生成 Strea...
-
Calcite - 看懂 Parser.jj 中的 SqlSelectjavacc 會根據(jù) parser.jj 中定義的相互穿插的 Token、Java 代碼來自動生成 org.apache.calcite.sql...