| 程序包 | 说明 |
|---|---|
| com.aliyun.odps.datahub |
ODPS Datahub服务用于上传、下载数据到ODPS
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");
.... |
| com.aliyun.odps.tunnel |
ODPS Tunnel服务用于上传、下载数据到ODPS
Examples:
Account account = new AliyunAccount("accessId", "accessKey");
Odps odps = new Odps(account);
odps.setDefaultProject("my_project");
DataTunnel tunnel = new DataTunnel(odps);
UploadSession session = tunnel.createUploadSession("my_project", "my_table");
.... |
| 限定符和类型 | 方法和说明 |
|---|---|
WritePackResult |
DatahubWriter.write(DatahubRecordPack recordPack)
向ODPS hub服务的非分区表写入一个pack
|
WritePackResult |
DatahubWriter.write(DatahubRecordPack recordPack,
byte[] meta)
向ODPS hub服务的非分区表写入一个pack
|
WritePackResult |
DatahubWriter.write(PartitionSpec partitionSpec,
DatahubRecordPack recordPack)
向ODPS hub服务的分区表写入一个pack
|
WritePackResult |
DatahubWriter.write(PartitionSpec partitionSpec,
DatahubRecordPack recordPack,
byte[] meta)
向ODPS hub服务的分区表写入一个pack
|
| 限定符和类型 | 方法和说明 |
|---|---|
void |
StreamUploadWriter.write(DatahubRecordPack recordPack)
向ODPS非分区表写入数据,第一次写入会自动load shard
|
void |
StreamUploadWriter.write(PartitionSpec partitionSpec,
DatahubRecordPack recordPack)
向ODPS分区表写入数据,第一次写入会自动load shard
|
Copyright © 2015 Alibaba Cloud Computing. All rights reserved.