基于以下sql 做一些分析
String sql = "select u.id as user_id, u.name as user_name, j.company as user_company, u.age as user_age" +
" from users u join jobs j on u.name=j.name" +
" where u.age > 30 and j.id>10" +
" order by user_id";
RelNode :
对关系的一种处理方式,Sort, project, join ,aggregate , filter , union,。 是把两个集合的关系做的一种处理。比如两个tableScan 做一个join 是是一个relnode。它蕴含的是对整个 Relation 的操作,而不是对具体数据的处理逻辑。
(只有这些针对整个关系表达式的的一个整体性操作才是relNode)
LogicalSort
LogicalProject —input
LogicalFilter — input
LogicalJoin 输入是left && right
LogicalTableScan(EnemrableTableScan) (内含RelOptTable) —left
LogicalTableScan(EnemrableTableScan) (内含RelOptTable) —right
RexNode
对具体某一行数据的某一列做的一个处理动作
rexNode 是对数据的一种表示,而不是对数据集的关系。
rexNode在处理每一行具体的数据,比如cast, rexLiteral
rexCall : 是函数表达式 , cast 等
rexLiteral : 常量表达式, “123”
对于一个LogicalFilter, 他的filter 是有条件的(condition),
这个condition 也就是 “u.age > 30 and j.id >10” 这个condition 就是一个rexCall ,op 的SqlKind 是AND,而oprands(两个被操作对象)也是两个rexCall
eg.
而age>30 这个rexcall, 他的op 是">" , SqlKind 是GreaterThan, 这个rexCall 的 左边age 是RexInputRef(因为每一列都被引用成了$1 等编号),而30 就是RexLiteral 就是rex 常量 。
所谓的Convert 过程,就是把上面sqlNode递归的翻译成relNode , sqlCall 翻译成 Rexnode 。
Calcite convert sqlNode -> relNode 几个方法调用
SqlToRelConverter
convertQueryRecursive
convertQuery
ConvertSelect
convertFrom
convertWhere
以以下一个sql 举例:
String sql = "select id,name from users where id <5 and name = 'zhang' ";
其中 id < 5 的debug 内容
> 上面还嵌套一个SqlBasicCall : and ,and 两遍的operands 一个是id<5 ,一个是name='zhang' ,**SqlCall 的kind 是and ,即是操作符的种类**
users.id < 5 (整体: 是一个SqlBasicCall) ,sqlCall 的kind 是LESS_THAN,
operator : < (binaryOpretor二元操作符 )
operands : 被操作符操作的两个对象
第一个 users.id (SqlIdentifier)
第二个 :5 (SqlNumericLiteral) -- SqlTypeName(是Decimal)
大概总结一下两者关系RelNode 和 RexNode 的区别 :
1 RelNode 关系表达式, 主要有TableScan, Project, Sort, Join等。如果SQL为查询的话,所有关系达式都可以在SqlSelect中找到, 如 where和having 对应的Filter, selectList对应Project, orderBy、offset、fetch 对应着Sort, From 对应着TableScan/Join等等, 示便Sql最后会生成如下RelNode树 LogicalProject LogicalFilter LogicalTableScan
2 RexNode 行表达式, 如RexLiteral(常量), RexCall(函数), RexInputRef(输入引用)等, 还是这一句SQL select id, cast(score as int), 'hello' from T where id < ?
, 其中id 为RexInputRef
, cast为RexCall
, 'hello' 为RexLiteral
等
RelOptPlanner :优化器
网友评论