95-908-030-源码-FlinkTable-Table API

蔚落 2022-09-10 11:09 172阅读 0赞

文章目录

  • 1.美图
  • 2.概述

1.美图

在这里插入图片描述

2.概述

​ 除了使用纯 SQL 语句的方式外, Flink 还支持 Table API 编程,对 Table API 的支持主要借助 Table, OperationExpression 等接口。

OperationExpression 是对操作和表达式的抽象,OperationExpression 都有一套各自的类继承层次,可以等同于 Calcite 中的 RelNodeRexNode。通过 Table API 接口,可以构建出语法树,这颗 Operation 树最终被转换为 RelNode 树,之后就是进入前面提到的转换和优化逻辑了。

Table 是对于表的抽象,除了 schema 等信息外,其底层对应的是一个 Qu

发表评论

表情:
评论列表 (有 0 条评论,172人围观)

还没有评论,来说两句吧...

相关阅读