FlinkKafkaConsumer010 ; import org . apache . flink . table . api . DataTypes ; import org . apache . flink . table . filesystem . stream .
TRIGGER、DROP TABLE、TRUNCATE TABLE、RENAME TABLE、DROP INDEX、CREATE INDEX 数据库账号权限要求 数据库 结构迁移 全量迁移 增量迁移 源端 SELECT SELECT SELECT,SHOW VIEW,SUPER,REPLICATION SLAVE 目标端 读写权限 读写权限 读写权限 操作步骤 登录 DTS 控制台 。
表), view(视图), function(函数), procedure(存储过程) table src String 否 源库的schema名称 test.table_src dst String 否 目标库的schema名称 test.table_dst where String 否 where过滤条件 where DetailConfig字段数据结构说明 参数名称 参数类型 是否必须 描述
TRIGGER、DROP TABLE、TRUNCATE TABLE、RENAME TABLE、DROP INDEX、CREATE INDEX 数据库账号权限要求 数据库 结构迁移 全量迁移 增量迁移 源端 SELECT SELECT SELECT,SHOW VIEW,SUPER,REPLICATION SLAVE 目标端 读写权限 读写权限 读写权限 操作步骤 登录 DTS 控制台 。
调用费 密钥API调用费用 = 密钥API调用次数 × API调用单价 0.00006元/次 凭据API调用费 凭据API调用费用 = 凭据API调用次数 × API调用单价 0.00006元/次 计费说明 总费用 = 密钥保管费 + 密钥API调用费 + 凭据保管费 + 凭据API调用费
TRIGGER、DROP TABLE、TRUNCATE TABLE、RENAME TABLE、DROP INDEX、CREATE INDEX 数据库账号权限要求 数据库 结构迁移 全量迁移 增量迁移 源端 SELECT SELECT SELECT,SHOW VIEW,SUPER,REPLICATION SLAVE 目标端 读写权限 读写权限 读写权限 操作步骤 登录 DTS 控制台 。
表), view(视图), function(函数), procedure(存储过程) table src String 否 源库的schema名称 test.table_src dst String 否 目标库的schema名称 test.table_dst where String 否 where过滤条件 where DetailConfig字段数据结构说明 参数名称 参数类型 是否必须 描述
对于老版本的表,可以使用以下方式增加隐藏列: ALTER TABLE tablename ENABLE FEATURE BATCH_DELETE ; 这个操作本质上是一个 Schema Change 操作,执行后,需通过 SHOW ALTER TABLE COLUMN 查看作业执行进度。
请求参数 参数名称 类型 是否必选 参数位置 描述 version String 是 URL参数 API版本号 instanceId String 是 URL参数 实例ID 返回头域 除公共头域,无其它特殊头域。
version String 是 API版本号 1 URL参数 dtsId String 是 任务ID dtsmxxxyyy URL参数 type String 是 任务类型(数据传输任务:migration),目前仅支持数据传输任务 migration Request Body 参数 dataType String[] 是 传输数据类型数组(schema:结构迁移;base:全量迁移;increment