Iceberg SQL 是基于 Apache Iceberg 的數據查詢接口。Apache Iceberg 是一種開源表格格式,用于大規模數據集,提供了高效的元數據處理和事務支持。以下是一些基本的 Iceberg SQL 語句示例,幫助你開始使用它。
CREATE TABLE my_table (
id INT,
name STRING,
timestamp TIMESTAMP
)
USING iceberg
PARTITIONED BY (date STRING);
INSERT INTO my_table (id, name, timestamp, date)
VALUES (1, 'Alice', '2023-04-01T12:00:00Z', '2023-04');
SELECT * FROM my_table;
UPDATE my_table
SET timestamp = '2023-04-01T13:00:00Z'
WHERE id = 1;
DELETE FROM my_table
WHERE id = 1;
SELECT * FROM my_table
WHERE date = '2023-04';
ALTER TABLE my_table ADD COLUMN new_column STRING;
ALTER TABLE my_table DROP COLUMN new_column;
ALTER TABLE my_table RENAME COLUMN old_column TO new_column;
DESCRIBE TABLE my_table;
SELECT * FROM my_table WHERE date = '2023-04';
Iceberg SQL 還支持許多高級功能,如事務、快照隔離、ACID 特性等。你可以查閱 Apache Iceberg 的官方文檔以獲取更多詳細信息。
請注意,這些示例假設你已經有一個運行中的 Iceberg 集群,并且你的環境已經配置好了相應的 JDBC 驅動和連接字符串。如果你使用的是不同的數據引擎或云服務提供商,可能需要調整連接字符串和配置。