文档首页 > > SDK参考> 使用SDK> 使用SDK(Java)> 更新转储任务

更新转储任务

分享
更新时间: 2019/08/27 GMT+08:00

参考初始化DIS客户端的操作初始化一个DIS客户端实例,实例名称为dic。

使用DIS SDK更新转储任务,需要指定通道名称、转储任务名称,转储周期,转储目标服务等信息。示例代码为“dis-sdk-demo\src\main\java\com\bigdata\dis\sdk\demo\example”目录下的“TransferTaskDemo.java”文件。

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
//需配置转储任务的全量参数,不支持更新单个参数
UpdateTransferTaskRequest request = new UpdateTransferTaskRequest();

// 配置待更新的转储任务所属通道的名称
request.setStreamName(streamName);

// 配置待更新的转储任务名称
OBSDestinationDescriptorRequest descriptor = new OBSDestinationDescriptorRequest();
descriptor.setTransferTaskName(taskName);

// 转储至对象存储服务(简称OBS):OBS桶名和子文件夹名,通过OBS控制台或客户端创建桶和文件夹
descriptor.setObsBucketPath("obs-dis1");
descriptor.setFilePrefix("transfertask");

// 转储周期,单位s
descriptor.setDeliverTimeInterval(300);

// 可选,转储OBS的目标文件格式:默认text,可配置parquet、carbon
descriptor.setDestinationFileType(DestinationFileTypeEnum.TEXT.getType());

request.setObsDestinationDescriptor(descriptor);

配置“UpdateTransferTaskRequest”对象之后,通过调用updateTransferTask的方法更新转储任务。

1
dic.updateTransferTask(request);
分享:

    相关文档

    相关产品

文档是否有解决您的问题?

提交成功!

非常感谢您的反馈,我们会继续努力做到更好!

反馈提交失败,请稍后再试!

*必选

请至少选择或填写一项反馈信息

字符长度不能超过200

提交反馈 取消

如您有其它疑问,您也可以通过华为云社区问答频道来与我们联系探讨

智能客服提问云社区提问