Flink SQL 的 catalog 局限性
Flink SQL Catalog 局限性 现阶段的 Flink SQL 元数据引用方式 Flink SQL 使用 calcite 框架作为 Flink SQL 的核心组建， calcite 虽然支持无限层的元数据结构，但 Flink SQL 中限制了元数据的组织结构为 3 级别 结构， 分别是 catalog, database, table 。 在 Flink SQL 中使用一张外部数据表， 大概有两种形式: 创建一个 catalog， 通过 catalog.database.table 来引用一张数据表. -- 使用 CREATE CATALOG DDL CREATE CATALOG my_catalog WITH( 'type' = 'jdbc', 'default-database' = '...', 'username' = '...', 'password' = '...', 'base-url' = '...' ); -- 使用 TableEnv 进行注册 HiveCatalog hiveCatalog = new HiveCatalog(); tbEnv....