| 核心 | _delta_log 日志 |
|---|---|
| 能力 | ACID/时光旅行 |
| 模式 | 写入强约束 |
| 生态 | Spark 为主 |
Delta 操作
Delta 操作
CREATE TABLE demo.db.trade_order (
order_id STRING,
pay_amt DECIMAL(18,2),
dt DATE
) USING delta PARTITIONED BY (dt);
MERGE INTO demo.db.trade_order t
USING stg_order s ON t.order_id = s.order_id
WHEN MATCHED THEN UPDATE SET t.pay_amt = s.pay_amt
WHEN NOT MATCHED THEN INSERT *;模式强制会拒绝不匹配写入，导入脏数据时需要显式开启合并模式（代价是类型放宽）。