1.美图

2.概述

为了使用 SQL，一个首先需要解决的是元数据管理的问题。元数据的管理包括表的元数据和 UDF 的元数据，这使得完全使用 SQL 语句来构建实时任务成为可能。

3.Catalog 和 CatalogManager

在 1.9 版本发布之前，Flink SQL 完全借助于 Calcite 的 Schema 接口来管理注册的表，并且提供了 ExternalCatalog 接口，通过 TableDescriptor 定义外部系统数据的来源，从而访问到外部系统的数据。但是 ExternalCatalog 的定义不是非常完整，并且不太方便和 Hive 等已有的元数据管理进行集成。为此，Flink SQL 重构并提供了 Catalog 接口，Catalog 接口能够支持数据库、表、函数、甚至于分区等多种抽象。通过 CatalogManager，可以同时在一个会话中挂载多个 Catalog，从而访问到多个不同的外部系统。

95-910-150-源码-FlinkSQL-Flink SQL 的元数据管理相关推荐

【Flink】Flink 源码阅读笔记（16）- Flink SQL 的元数据管理
1.概述转载:Flink 源码阅读笔记(16)- Flink SQL 的元数据管理 Flink 源码阅读笔记(17)- Flink SQL 中的时间属
SharingSphere 源码解析 -- 真实SQL生成探索
SharingSphere 源码解析 – 真实SQL生成探索简介在上一篇文章中,我们探索了ShardingSphere JDBC Mybatis示例执行的一个大致的过程,找到了SQL处理的关键节点 ...
gRPC-go源码（1）：连接管理
gRPC-go源码(1):连接管理 1 写在前面在这个系列的文章中,我们将会从源码的层面学习和理解gRPC. 整个系列的文章的计划大概是这样的:我们会先从客户端开始,沿着调用路径逐步分析到服务端,以 ...
（附源码）计算机毕业设计SSM加油站管理信息系统
(附源码)计算机毕业设计SSM加油站管理信息系统项目运行环境配置: Jdk1.8 + Tomcat7.0 + Mysql + HBuilderX(Webstorm也行)+ Eclispe(Inte ...
（附源码）计算机毕业设计SSM健身房管理系统设计
(附源码)计算机毕业设计SSM健身房管理系统设计项目运行环境配置: Jdk1.8 + Tomcat7.0 + Mysql + HBuilderX(Webstorm也行)+ Eclispe(Inte ...
淘宝数据库OceanBase SQL编译器部分源码阅读--解析SQL语法树
http://blog.csdn.net/qq910894904/article/details/28658421 OceanBase是阿里巴巴集团自主研发的可扩展的关系型数据库,实现了跨行跨表的事务 ...
sharding-jdbc源码解析之sql解析
2019独角兽企业重金招聘Python工程师标准>>> 说在前面本文转自"天河聊技术"微信公众号本次介绍的是sharding-jdbc的源码解析部分的sql解 ...
MyBatis(12) 源码解析之SQL执行流程
一.前言资料 mybatis文档:https://mybatis.org/mybatis-3/index.html mybatis源码:https://github.com/mybatis/myba ...
mysql 执行概况_转mysql源码分析之SQL执行过程简介
本人打算从SQL语句的执行开始学习和分析MYSQL源码,首先了解MYSQL是如何执行一条SQL语句的,详细了解它的执行过程之后,再深入学习执行一条SQL语句的运行原理. 1)从执行一条SQL语句的堆栈 ...
C/S系统快速开发框架/winform快速开发框架源码（C#+SQL）
C/S系统快速开发框架正在席卷软件和应用程序开发领域,winform所提供的开发速度的提高.在开发周期中适应客户需求的灵活性.成本效益和更高的客户满意度,正迅速使其成为应用程序开发的新标准. C/S和 ...

95-910-150-源码-FlinkSQL-Flink SQL 的元数据管理

1.美图

2.概述

3.Catalog 和 CatalogManager

95-910-150-源码-FlinkSQL-Flink SQL 的元数据管理相关推荐

最新文章

热门文章