HiveSink

    {
        "boosterClass":"com.oceanbase.oms.connector.jdbc.sink.obmysql.OBMySQLJDBCSinkBooster",
        "type":"JDBC_SINK_OB_MYSQL/JDBC_SINK_OB_MYSQL_DIRECT_LOAD",
        "insertMode":"INSERT",
        "jdbcUrl":"jdbc:mysql://xxx.xxx.xxx.xxx:2883?useUnicode=true&allowMultiQueries=true&socketTimeout=50000&characterEncoding=utf8&readOnlyPropagatesToServer=false",
        "username":"xxx@xxx#xxx",
        "password":"xxx",
            "jar":"jdbc-sink-ob-mysql.jar",
        // If you do not specify a name for the result table, it is named in the format of oms_result_xxx, where xxx is the name of the target table.
        "saveResult":"true",
        "resultTable":{"schema":"hive","table":"oms_result_migrate"},
        "dbVersion":"4.3.4.0",
            "timezone":"+08:00",
            "workerNum":"4"
        }

    create table if not exists oms_result_migrate (
    id bigint not null auto_increment,
    schema_name varchar(128) not null,
    table_name varchar(128) not null,
    result_type varchar(1) not null comment 'i-insert,d-delete,u-update,e-error',
    rows bigint not null,
    gmt_create timestamp(6) default current_timestamp(6),
    data longtext,
    message text,
    primary key(id),
    index idx_schema_table(schema_name,table_name,result_type)
    );