CREATE EXTERNAL CATALOG
CREATE EXTERNAL CATALOG 用于创建 External Catalog,使 AnalyticDB for MySQL 能够访问外部数据湖(Hive、Iceberg、Delta、Paimon)或兼容 MySQL 协议的外部数据库。
语法
CREATE EXTERNAL CATALOG <catalog_name>
[COMMENT "<comment>"]
PROPERTIES (
"key" = "value"[, ...]
);
参数
|
参数 |
必填 |
说明 |
|
|
是 |
Catalog 名称。命名规则:以小写字母开头,可包含小写字母、数字和下划线(_),长度为 2~64 个字符。 |
|
|
否 |
Catalog 的说明信息。 |
|
|
是 |
Catalog 类型。取值: |
|
|
是 |
Catalog 的连接属性。不同类型的 Catalog 需要的属性不同,详情请参见 External Catalog。 |
示例
示例一:创建名为 hive_hms_catalog 的 Hive Catalog,使用 Hive Metastore 作为元数据服务。
CREATE EXTERNAL CATALOG hive_hms_catalog
PROPERTIES (
"type" = "hive",
"hive.metastore.uris" = "thrift://xx.xx.xx.xx:9083"
);
示例二:创建名为 iceberg_hms_catalog 的 Iceberg Catalog,使用 Hive Metastore 作为元数据服务。
CREATE EXTERNAL CATALOG iceberg_hms_catalog
PROPERTIES (
"type" = "iceberg",
"hive.metastore.uris" = "thrift://xx.xx.xx.xx:9083"
);
示例三:创建名为 paimon_fs_catalog 的 Paimon Catalog,使用 FileSystem 作为元数据服务。
CREATE EXTERNAL CATALOG paimon_fs_catalog
PROPERTIES (
"type" = "paimon",
"paimon.catalog.metastore" = "filesystem",
"paimon.catalog.warehouse" = "oss://test_bucket/test_path/test_warehouse/"
);
使用说明
-
创建 External Catalog 前,需确保集群与目标数据源之间网络互通。
-
不同类型 Catalog 的必要属性和可选属性,请参见 External Catalog。
-
各类型 Catalog 的版本要求如下:
-
Paimon Catalog:AnalyticDB for MySQL 3.2.7 及以上版本。
-
Hive Catalog:AnalyticDB for MySQL 3.2.8 及以上版本。
-
Iceberg Catalog:AnalyticDB for MySQL 3.2.8 及以上版本。
-
Delta Lake Catalog:AnalyticDB for MySQL 3.2.8 及以上版本。
-
MySQL Catalog:AnalyticDB for MySQL 3.2.8 及以上版本。
-