文档首页/ MapReduce服务 MRS/ 组件操作指南(LTS版)/ 使用Iceberg(MRS 3.6.0.1及之后版本)/ 基于Spark使用Iceberg/ Iceberg DML语法说明/ 写入分支数据
更新时间:2026-06-11 GMT+08:00
写入分支数据
基本语法
在执行写入操作前,目标分支必须已存在,写入操作不会自动创建不存在的分支。创建分支操作可参考Branch。
- 通过SQL语句写入分支
分支写入可通过在操作中指定分支标识符branch_yourBranch实现。也可通过指定spark.wap.branch配置,在写入-审计-发布(WAP)工作流中执行分支写入。需注意,不能同时指定WAP分支和分支标识符。
MERGE INTO分支数据:
MERGE INTO prod.db.table.branch_audit_branch t USING (SELECT ...) s ON t.id = s.id WHEN ...;
UPDATE分支数据:
UPDATE prod.db.table.branch_audit_branch AS t1 SET val = 'c';
删除分支数据:
DELETE FROM prod.dbl.table.branch_audit_branch WHERE id = 2;
WAP写入分支:
- 配置spark.wap.branch:
SET spark.wap.branch = audit_branch;
- 插入数据:
INSERT INTO prod.db.table VALUES (3, 'c');
- 配置spark.wap.branch:
父主题: Iceberg DML语法说明