| 能力 | ACID/快照/演进 |
|---|---|
| 存储 | HDFS/对象存储 |
| 引擎 | Spark/Flink/Trino |
| 访问 | Catalog+表标识 |
Spark 建表
Spark 建表
CREATE TABLE demo.db.trade_order (
order_id STRING,
store_id STRING,
pay_amt DECIMAL(18,2),
dt DATE
) USING iceberg
PARTITIONED BY (dt);
INSERT INTO demo.db.trade_order VALUES ('O1','S1',100.00, DATE '2026-10-12');Iceberg 的提交是原子性的:读到的要么是旧快照,要么是新快照,不会读到半成品。