文档首页 > > SDK参考> 使用SDK> 使用SDK(Java)> 新增Checkpoint

新增Checkpoint

分享
更新时间: 2020/03/23 GMT+08:00

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

使用DIS SDK创建Checkpoint,需要指定通道名称、APP名称、分区编号、序列号以及Checkpoint类型。

其中,“streamName”的配置值要与开通DIS通道“Stream Name”的值一致。

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
// 通道名称 
String streamName = "myStream"; 
// APP名称
String appName = "myApp";
CommitCheckpointRequest commitCheckpointRequest = new CommitCheckpointRequest();
commitCheckpointRequest.setStreamName(streamName);
commitCheckpointRequest.setAppName(appName);
// 需要提交的sequenceNumber
commitCheckpointRequest.setSequenceNumber("100");
// 分区编号
commitCheckpointRequest.setPartitionId("0");
// Checkpoint类型
commitCheckpointRequest.setCheckpointType(CheckpointTypeEnum.LAST_READ.name());

配置“CommitCheckpointRequest”对象之后,通过调用 commitCheckpoint 提交checkpoint。

dic.commitCheckpoint(commitCheckpointRequest);
分享:

    相关文档

    相关产品

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

提交成功!

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

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

*必选

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

字符长度不能超过200

提交反馈 取消

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

智能客服提问云社区提问