检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
使用SDK(Java) 准备环境 配置样例工程 初始化DIS客户端 创建通道 添加转储任务 更新转储任务 删除转储任务 查询转储列表 查询转储详情 删除通道 查询通道列表 查询通道详情 下载流式数据 上传流式数据 获取数据游标 创建APP 删除APP 新增Checkpoint 查询Checkpoint
础开发您的应用。示例工程代码路径:“\dis-sdk-demo\src\main\java\com\bigdata\dis\sdk\demo”。 示例代码 说明 ConsumerDemo.java 展示了下载数据的用法 ProducerDemo.java 展示了上传数据的用法 操作步骤
初始化DIS客户端 您可以使用以下两种方法初始化DIS SDK客户端实例,优先选择使用代码进行初始化。其中,“endpoint”,“ak”,“sk”,“region”,“projectId”信息请参考获取认证信息。 使用代码初始化DIS SDK客户端实例。 1 2 3 4 5 6 7
getMessage(), e); } } } 下载数据方式选择TRIM_HORIZON和 LATEST时,样例代码示例如下,参见加粗代码行,基于demo注释掉startingSequenceNumber字段。 1 2 3 4 5 6 7 8 9 10
上传流式数据 样例代码 使用初始化DIS客户端后的客户端实例将用户的流式数据通过DIS通道上传至DIS服务。 其中,“streamName”的配置值要与开通DIS通道中“通道名称”的值一致,“endpoint”,“ak”,“sk”,“region”,“projectId”信息请参见获取认证信息。
已从Oracle官网下载并安装JDK1.8或以上版本,配置好JAVA环境变量。 已从Eclipse官网下载并安装Eclipse IDE for Java Developers最新版本。 已在Eclipse中配置好JDK。 父主题: 使用SDK(Java)
配置APP名称之后,通过调用deleteApp的方法删除APP。 dic.deleteApp(myApp); 父主题: 使用SDK(Java)
13288589]'}], hasMorePartitions=false, updatePartitionCounts=null] 父主题: 使用SDK(Java)
ansferTask的方法删除转储任务。 1 dic.deleteTransferTask(request); 父主题: 使用SDK(Java)
ansferTask的方法创建转储任务。 1 dic.createTransferTask(request); 父主题: 使用SDK(Java)
getCheckpoint: {"sequence_number": "10", "metadata": "metadata"} 父主题: 使用SDK(Java)
Stream的方法删除通道。 1 dic.deleteStream(deleteStreamRequest); 父主题: 使用SDK(Java)
"deliver_time_interval":300, "consumer_strategy":"LATEST" } } 父主题: 使用SDK(Java)
配置APP名称之后,通过调用createApp的方法创建APP。 dic.createApp(myApp); 父主题: 使用SDK(Java)
":1552458158527 } ], "total_number":2 } 父主题: 使用SDK(Java)
Stream的方法创建通道。 1 dic.createStream(createStreamRequest); 父主题: 使用SDK(Java)
ansferTask的方法更新转储任务。 1 dic.updateTransferTask(request); 父主题: 使用SDK(Java)
提交checkpoint。 dic.commitCheckpoint(commitCheckpointRequest); 父主题: 使用SDK(Java)
[currentPartitionCount=2, streamName=mystream, targetPartitionCount=2] 父主题: 使用SDK(Java)
equest); String cursor = response.getPartitionCursor(); 父主题: 使用SDK(Java)