iceberg sql如何用

Iceberg SQL 是基于 Apache Iceberg 的 SQL 查询接口，用于处理大规模数据集。以下是一些基本的使用步骤和示例：

1. 创建表

使用 CREATE TABLE 语句创建一个新的表。例如，以下语句创建一个名为 my_table 的表，其中包含 id、name 和 timestamp 三个列：

CREATE TABLE my_table (
  id INT,
  name STRING,
  timestamp TIMESTAMP
)
USING iceberg;

2. 插入数据

使用 INSERT INTO 语句向表中插入数据。例如，以下语句向 my_table 表中插入三条记录：

INSERT INTO my_table (id, name, timestamp)
VALUES (1, 'Alice', '2023-01-01 00:00:00'),
       (2, 'Bob', '2023-01-02 00:00:00'),
       (3, 'Charlie', '2023-01-03 00:00:00');

3. 查询数据

使用 SELECT 语句查询表中的数据。例如，以下语句查询 my_table 表中的所有记录：

SELECT * FROM my_table;

你还可以使用 WHERE 子句过滤结果，使用 ORDER BY 子句排序结果，以及使用聚合函数（如 COUNT()、SUM() 等）进行数据处理。

4. 更新数据

Iceberg SQL 支持部分更新表中的数据。你可以使用 UPDATE 语句来更新满足特定条件的记录。例如，以下语句将 my_table 表中 name 列值为 ‘Alice’ 的记录的 timestamp 列值更新为 ‘2023-01-05 00:00:00’：

UPDATE my_table
SET timestamp = '2023-01-05 00:00:00'
WHERE name = 'Alice';

5. 删除数据

Iceberg SQL 支持删除表中的数据。你可以使用 DELETE 语句来删除满足特定条件的记录。例如，以下语句删除 my_table 表中 timestamp 列值小于 ‘2023-01-02 00:00:00’ 的记录：

DELETE FROM my_table
WHERE timestamp < '2023-01-02 00:00:00';

注意：以上示例假设你已经正确配置了 Iceberg 和相关的依赖项。在实际使用中，你可能需要根据你的具体环境和需求进行适当的调整和优化。