Iceberg Catalog是一種External Catalog。通過Iceberg Catalog,您可以直接查詢Iceberg中的數據。本文為您介紹如何在E-MapReduce的StarRocks集群上創建和查看Iceberg Catalog。
前提條件
使用限制
創建的兩個集群需要在同一個VPC下,并且在同一個可用區下。
StarRocks當前支持查詢Versions 1表(Analytic Data Tables),暫不支持查詢Versions 2表(Row-level Deletes)。兩種表的詳細信息請參見Iceberg Table Spec。
創建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
。hive.metastore.uris
否
Hive MetaStore的URI。格式為
thrift://<Hive MetaStore的IP地址>:<端口號>
,端口號默認為9083。當使用DLF的元數據時,該配置可省略。
示例
以下示例創建了一個名為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概述。