| 程序包 | 说明 |
|---|---|
| com.aliyun.odps |
提供操作ODPS基本资源的类
ODPS基本资源包括: Table, Resource, Function等
Examples:
Account account = new AliyunAccount("accessId", "accessKey");
Odps odps = new Odps(account);
odps.setDefaultProject("my_project");
for (Table t : odps.tables()) {
System.out.print(t.getName() + "\t" + t.getOwner());
}
|
| com.aliyun.odps.data |
提供表示ODPS中记录的数据结构定义
|
| 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");
.... |
| 限定符和类型 | 方法和说明 |
|---|---|
TableSchema |
Table.getSchema()
获取表结构定义
|
| 限定符和类型 | 方法和说明 |
|---|---|
void |
Tables.create(String projectName,
String tableName,
TableSchema schema)
创建表
|
void |
Tables.create(String projectName,
String tableName,
TableSchema schema,
boolean ifNotExists)
创建表
|
void |
Tables.create(String tableName,
TableSchema schema)
创建表
|
void |
Tables.create(String tableName,
TableSchema schema,
boolean ifNotExists)
创建表
|
| 构造器和说明 |
|---|
DefaultRecordReader(InputStream is,
TableSchema tableSchema)
构造一个 DefaultRecordReader
|
| 限定符和类型 | 方法和说明 |
|---|---|
TableSchema |
TableTunnel.UploadSession.getSchema()
获取表结构
|
TableSchema |
TableTunnel.DownloadSession.getSchema()
获取数据对应的表结构
|
TableSchema |
DownloadSession.getSchema()
已过时。
获取数据对应的表结构
|
TableSchema |
UploadSession.getSchema()
已过时。
获取表结构
|
TableSchema |
StreamClient.getStreamSchema() |
Copyright © 2015 Alibaba Cloud Computing. All rights reserved.