数据接入服务 DIS-新增Checkpoint
新增Checkpoint
参考初始化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);
- MapReduce服务_什么是Flink_如何使用Flink
- AI训练加速存储_高性能数据存储_AI数据存储内存不足怎么办
- 如何进行日志采集和转储_日志平台_日志接入_日志转储
- 数据存储共享_文件存储应用场景_共享文件存储SFS
- web应用防火墙新增策略_web应用防火墙添加规则_web应用防火墙添加域名
- 文件存储与块存储的区别_免费的文件存储_分布式文件存储系统
- GaussDB底层硬件_gaussdb介绍_高斯数据库底层硬件_华为云
- 大数据应用范围有哪些_大数据技术与应用要学习什么课程
- 云日志服务有哪些功能_云日志服务平台_日志管理-华为云
- GaussDB的研发历程_GaussDB产品动态_高斯数据库研发历程-华为云