文档

Iceberg数据源

更新时间:

通过Iceberg Catalog,您可以直接查询Iceberg中的数据。本文为您介绍如何创建和查看Iceberg Catalog。

创建Iceberg Catalog

语法

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

参数说明

  • catalog_name:Iceberg Catalog的名称,必选参数。命名要求如下:

    • 必须由字母(a~z或A~Z)、数字(0~9)或下划线(_)组成,并且只能以字母开头。

    • 总长度不能超过64个字符。

  • PROPERTIES:Iceberg Catalog的属性,必选参数。Iceberg使用的元数据服务不同,该参数的配置也不同。Iceberg Catalog的作用是保存Iceberg表和其存储路径的映射关系。

    属性

    是否必选

    说明

    type

    数据源类型,取值为iceberg

    iceberg.catalog.type

    Iceberg中Catalog的类型。当使用Hive MetaStore的元数据时,请设置该参数为hive。当使用DLF的元数据时,请设置参数值为dlf

    hive.metastore.uris

    Hive MetaStore的URI。格式为thrift://<Hive MetaStore的IP地址>:<端口号>,端口号默认为9083。

    dlf.catalog.id

    DLF数据目录ID。仅当iceberg.catalog.type配置为dlf时需要填写该参数。如果未配置dlf.catalog.id参数的值,则系统将使用默认的DLF Catalog。

示例

以下示例创建了一个名为iceberg_catalog的Iceberg Catalog。

CREATE EXTERNAL CATALOG iceberg_catalog
PROPERTIES
(
    "type" = "iceberg",
    "iceberg.catalog.type" = "hive",
    "hive.metastore.uris" = "thrift://xx.xx.xx.xx:9083"
);

查看Iceberg表数据

您可以通过SELECT查询目标数据库中的目标表。

SELECT * FROM <catalog_name>.<database_name>.<table_name>;

相关文档

Iceberg更多介绍,请参见Iceberg概述