更新时间: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写入分支:

    1. 配置spark.wap.branch
      SET spark.wap.branch = audit_branch;
    2. 插入数据:
      INSERT INTO prod.db.table VALUES (3, 'c');

相关文档