CREATE EXTERNAL CATALOG

更新时间:
复制为 MD 格式

CREATE EXTERNAL CATALOG 用于创建 External Catalog,使 AnalyticDB for MySQL 能够访问外部数据湖(Hive、Iceberg、Delta、Paimon)或兼容 MySQL 协议的外部数据库。

语法

CREATE EXTERNAL CATALOG <catalog_name>
[COMMENT "<comment>"]
PROPERTIES (
  "key" = "value"[, ...]
);

参数

参数

必填

说明

catalog_name

Catalog 名称。命名规则:以小写字母开头,可包含小写字母、数字和下划线(_),长度为 2~64 个字符。

COMMENT

Catalog 的说明信息。

type

Catalog 类型。取值:hiveicebergdeltapaimonmysql

property_key / property_value

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 及以上版本。

相关文档