Account account = new AliyunAccount("accessId", "accessKey");
Odps odps = new Odps(account);
odps.setDefaultProject("my_project");
DatahubClient client = new DatahubClient(odps);
DatahubReader reader = client.openDatahubReader("shardId");
DatahubWriter writer = client.openDatahubWriter("shardId");
....请参阅: 说明
| 接口 | 说明 |
|---|---|
| DatahubConstants |
DatahubConstants defined for ODPS.
|
| PackType |
| 类 | 说明 |
|---|---|
| DatahubClient | |
| DatahubConfiguration |
ODPS Datahub 配置项
用于保存与ODPS Datahub服务通讯过程需要的配置信息。
|
| DatahubHttpHeaders | |
| DatahubReader | |
| DatahubRecordPack | |
| DatahubWriter | |
| PackReader | |
| ReadPackResult | |
| ReplicatorStatus | |
| SeekPackResult | |
| WritePackResult |
| 枚举 | 说明 |
|---|---|
| DatahubClient.ShardState |
shard的状态
|
| PackType.ReadMode |
| 异常错误 | 说明 |
|---|---|
| DatahubException |
该异常在DataHub服务访问失败时抛出。
|
Examples:
Account account = new AliyunAccount("accessId", "accessKey");
Odps odps = new Odps(account);
odps.setDefaultProject("my_project");
DatahubClient client = new DatahubClient(odps);
DatahubReader reader = client.openDatahubReader("shardId");
DatahubWriter writer = client.openDatahubWriter("shardId");
....
Copyright © 2015 Alibaba Cloud Computing. All rights reserved.