开发者社区> 问答> 正文

FlinkSQL 的是如何怎样的呢?

FlinkSQL 的是如何怎样的呢?

展开
收起
游客4iodw4vsbx244 2021-12-08 17:02:20 501 0
1 条回答
写回答
取消 提交回答
  • 构建抽象语法树的事情交给了 Calcite 去做。SQL query 会经过 Calcite 解析器转变成 SQL 节点树,通过验证后构建成 Calcite 的抽象语法树(也就是图中的 Logical Plan)。另一边,Table API 上的调用会构建成 Table API 的抽象语法树,并通过 Calcite 提供的 RelBuilder 转变成 Calcite 的抽象语法树。然后依次被转换成逻辑执行计划和物理执行计划。

    在提交任务后会分发到各个 TaskManager 中运行,在运行时会使用 Janino 编译器编译代码后运行。

    2021-12-08 17:03:06
    赞同 展开评论 打赏
问答分类:
问答地址:
问答排行榜
最热
最新

相关电子书

更多
《基于Apache Hudi的CDC数据入湖》 立即下载
任庆盛|Flink CDC + Kafka 加速业务实时化 立即下载
基于 Flink SQL + Paimon 构建流式湖仓新方 立即下载

相关实验场景

更多