检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
荐您启用数据开发调度即可,无需配置CDM定时任务。 定时任务功能原理:采用Java Quartz定时器,类似Cron表达式配置。对起始时间解析出分,小时,天,月。构造出cronb表达式。 以配置天调度为例:重复周期选择1天:若当前时间2022/10/14 12:00,配置起始时间为2022/10/14
数据表ID,只读。 logic_tb_name String 逻辑实体名。 logic_tb_guid String 逻辑实体的guid,只读。 description String 描述。 status String 实体的发布状态,只读,创建和更新时无需填写。 枚举值: DRAFT: 草稿 PUBLISH_DEVELOPING:
200) { String filePath = "d:"; String fileName = "job.zip"; FileOutputStream fileOutputStream = new FileOutputStream(filePath
great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted
可使用的调优参数具体如下: 表1 全量阶段优化参数 参数名 类型 默认值 说明 scan.incremental.snapshot.backfill.skip boolean true 全量阶段是否跳过读取binlog数据,默认为true。跳过读取binlog数据可以有效降低内存使用。需要注意的
great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted
great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted
great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted
great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted
great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted
great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted
段类型的长度。 字段值:目的端DWS表新增字段的取值来源。 表9 附加字段取值方式 类型 示例 常量 任意字符 内置变量 源端host ip地址:source.host 源端schema名称:source.schema 源端table名称:source.table 目的端schema名称:target
字段类型:目的端Hudi表新增字段的类型。 字段值:目的端Hudi表新增字段的取值来源。 表9 附加字段取值方式 类型 示例 常量 任意字符 内置变量 源端host ip地址:source.host 源端schema名称:source.schema 源端table名称:source.table 目的端schema名称:target
数据表ID,只读。 logic_tb_name String 逻辑实体名。 logic_tb_guid String 逻辑实体的guid,只读。 description String 描述。 status String 实体的发布状态,只读,创建和更新时无需填写。 枚举值: DRAFT: 草稿 PUBLISH_DEVELOPING:
running_count 否 Integer 运行中的实例数量 running_exception_count 否 Integer 异常的实例数量。 skip_count 否 Integer 跳过的实例数量 success_count 否 Integer 运行成功的实例数量 waiting_confirm_count
参考新建离线处理集成作业创建一个单任务数据迁移作业。 在键盘上按F12,打开创建好的单任务数据迁移作业,选择“network”页签。该任务请求方式为getPipeline。 图1 请求方式getPipeline 在“Preview”的jobBody里面的“value”字段获取JSON消息体的内容。 图2 JSON消息体内容
String 编码,ID字符串。 name_en String 原子指标英文名。 name_ch String 原子指标英文名。 description String 描述。 create_by String 创建人。 cal_exp String 计算表达式,形如'sum(${f
"time_field_id" : null, "common_conditions" : [ ], "monitor" : null, "description" : "" } ] 响应示例 状态码: 200 Success,返回data数据是 BatchOperationVO。 { "data"
Parquet格式:UNCOMPRESSED、SNAPPY。 SequenceFile格式:UNCOMPRESSED、SNAPPY、GZIP、LZ4、BZIP2。 TextFile格式:UNCOMPRESSED。 OBS存储路径 指定OBS文件存储的路径,支持填写#{source_Top
复合指标ID,ID字符串。更新时必填。 name_en String 复合指标英文名称。 name_ch String 复合指标名称。 description String 描述 dimension_group String 统计维度ID,更新时不可修改此值。 group_name String