检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
ImportDefaultCategoryResultDto 参数 参数类型 描述 import_status String 导入状态 success 导入成功 failed 导入失败 import_error_message String 导入错误原因。 children Array of Import
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
作业进度,失败时为“-1”,其它情况为0~100。 status String 作业状态: BOOTING:启动中。 FAILURE_ON_SUBMIT:提交失败。 RUNNING:运行中。 SUCCEEDED:成功。 FAILED:失败。 UNKNOWN:未知。 NEVER_EXECUTED:未被执行。 isStopingIncrement
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
X-Auth-Token 是 String IAM Token,Token获取请参见认证鉴权。 表3 请求Body参数 参数 是否必选 参数类型 描述 detail 否 String 仅填写处理意见或者关闭问题时使用该字段,填写为相关意见或关闭说明。 operator 否 String 仅问题移交他人时使用该字段,选择移交负责人。
SQL作业。 图2 创建Spark SQL单任务作业 配置与Hudi相对应的Spark数据连接,并选中需要操作Hudi表对应的数据库。 图3 配置连接与数据库 根据实际情况配置compaction的调度周期。 图4 配置调度周期 填写Spark SQL的compaction语句,提交并运行作业。
上传存量数据 使用华为云专线,搭建用户本地数据中心与华为云VPC之间的专属连接通道。 创建OBS桶,并记录OBS的访问域名、端口和AK/SK。 创建CDM集群。 DataArts Studio实例中已经包含一个CDM集群(试用版除外),如果该集群已经满足需求,您无需再购买数据集成增量包,可以跳过这部分内容。
表达式:StringUtils.contains(value,"a") 如果字符串中包含指定字符串的任一字符,则返回布尔值true,否则返回false。例如“zzabyycdxx”中包含“z”或“a”任意一个,则返回true。 表达式:StringUtils.containsAny(value,"za")
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
采集的视图来源,dws视图逆向使用。 target_table_name 否 String 目的表名称。 details 否 Array of TableMappingDetailVO objects 详情。 source_tables 否 Array of MappingSourceTableVO
] } 失败响应 HTTP状态码 400 { "error_code":"DLF.0815", "error_msg":"Fail to read OBS file." } 状态码 状态码请参见状态码。 父主题: 作业开发API
表3 参数说明 参数名 是否必选 参数类型 说明 release_package 是 object 发布包详情,参考表4。 task_details 是 array[object] 发布任务详情,参考表5。 表4 发布包详情的参数说明 参数名 是否必选 参数类型 说明 apply_timestamp
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
"password": "********", "domain": { "name": "domainname" } }
进行配置。例如包含Import GES节点的作业,您只需要创建自定义策略,并勾选ges:graph:getDetail(查看图详情),ges:jobs:getDetail(查询任务状态),ges:graph:access(使用图)这三个授权项即可。 当满足如下条件之一时,MRS集群才支持委托方式提交作业。
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
public static void main(String[] args) { // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great
} 失败响应 HTTP状态码 400 { "error_code":"DLF.0815", "error_msg":"Fail to read OBS file." } 状态码 状态码请参见状态码。 父主题: 连接管理API(待下线)