Apache Flink Table API中的Catalog是如何实现数据源管理的？

本文共计532个文字，预计阅读时间需要3分钟。

Apache Flink的Table API提供了将数据注册为Table的方法，并支持通过SQL进行数据计算。这两种API实现了Apache Flink批流统一系统的实现方式。

一文了解ApacheFlinkCa

“Apache Flink的Table API提供了对数据注册为Table的方式， 实现把数据通过SQL的方式进行计算。Table API与SQL API实现了Apache Flink的批流统一的实现方式。Table API与SQL API的核心概念就是TableEnviroment。TableEnviroment对象提供方法注册数据源与数据表信息。那么数据源与数据表的信息则存储在CataLog中。所以，CataLog是TableEnviroment的重要组成部分。”

Apache Flink在获取TableEnviroment对象后，可以通过Register实现对数据源与数据表进行注册。注册完成后数据库与数据表的原信息则存储在CataLog中。CataLog中保存了所有的表结构信息、数据目录信息等。

内部CataLog注册

内部Table注册通过TableEnviroment的Register接口对数据进行注册。TableEnviroment的registerTable包含两个参数("tableName",table)。tableName就是注册在CataLog中的表名。第二个参数table则是对应的Table对象。Table则是由TableEnviroment生成得来或者是通过DataSet、DataStream转换的来。