程序包 com.aliyun.odps
的使用

使用com.aliyun.odps的程序包

程序包	说明
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.account	提供ODPS支持的账号类型
com.aliyun.odps.data	提供表示ODPS中记录的数据结构定义
com.aliyun.odps.task	提供ODPS支持的Task定义
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"); ....

com.aliyun.odps使用的com.aliyun.odps中的类

类和说明
FileResource FileResource表示ODPS中一个文件类型资源
Function Function表示ODPS中的函数
Functions 表示ODPS内所有Function的集合
Instance Instance表示ODPS中计算任务的一个运行实例
Instance.Result
Instance.StageProgress StageProgress表示Task执行过程中各阶段的进度统计
Instance.Status Instance的运行状态。
Instance.TaskStatus Task执行状态
Instance.TaskStatus.Status Instance中Task的状态
Instance.TaskSummary TaskSummary包含Task运行结束后的汇总信息 Summary信息以key-value对的形式组织
InstanceFilter InstanceFilter用于查询所有Instance时根据条件过滤 例如: InstanceFilter filter = new InstanceFilter(); filter.setFromTime(fromTime); filter.setEndTime(endTime); filter.setStatus(Instance.Status.TERMINATED); for (Instance i : odps.instances().iterator(filter)) { // do somthing on the Instance object }
Instances Instances表示ODPS中所有Instance的集合
Job ODPS Job定义。
LazyLoad LazyLoad表示此类型的属性值可能是延迟加载的 延迟加载的含义是, 对象的属性值可能不存在，在调用gets等方法时视需要通过RESTful API从服务器断获取
LogType 日志类型。
Odps Odps类是ODPS SDK的入口 构造Odps对象: Account account = new AliyunAccount("my_access_id", "my_access_key"); Odps odps = new Odps(account); odps.setDefaultProject("my_project"); for (Table t : odps.tables()) { .... } 设置默认Project: SDK中很多集合类上提供的方法有两个版本，比如: odps.tables().get("table_name") odps.tables().get("project_name", "table_name") 第一个版本的函数会使用Odps对象上保存的默认Project，设置默认Project的方法如下: odps.setDefaultProject("my_project");
OdpsException ODPS SDK产生的异常
OdpsHook OdpsHook 对象，用于在提交作业前后插入代码
OdpsHooks OdpsHooks 类 注册 OdpsHook 类 用于在启动 Instance 前后分别运行插件代码 一个 OdpsHooks 实例针对一个 Instance， 包含了一组实例化的 OdpsHook 对象
Partition Partition类的对象表示ODPS分区表中一个特定的分区
Project ODPS项目空间
Project.Status 项目空间状态
Projects Projects表示ODPS中所有Project的集合
Resource Resource表示ODPS中的资源
Resource.Type 表示ODPS中资源的类型
Resources Resources 表示ODPS内所有Resource的集合，可以通过此对象可以创建、删除和浏览 各种Resource类型。
Shard Created by yinyue on 15-3-17.
StreamJobs StreamJobs表示ODPS中所有StreamJob的集合
Table Table表示ODPS中的表
TableFilter TableFilter用于查询所有表时根据条件过滤表 注: 表名是指表名的前缀 例如: TableFilter filter = new TableFilter(); filter.setName("my_table_prefix"); for (Table t : odps.tables().iterator(filter)) { // do somthing on the Table object }
TableResource TableResource表示ODPS中一个表资源
Tables Tables表示ODPS中所有Table的集合
TableSchema TableSchema表示ODPS中表的定义
Task ODPS的Task定义
Task.Properties Task properties
Task.Property Task property
Topologies Topologies表示ODPS中所有Topology的集合
Topology Topologies表示ODPS中所有Topology的集合
Volume Volume表示ODPS中的volume 暂未开放，仅限内部使用
VolumeFile VolumeFile表示ODPS中的volume file 暂未开放，仅限内部使用
VolumeFilter VolumeFilter用于查询所有Volume或partition时根据条件过滤Volume或partition 暂未开放，仅限内部使用 注: Volume名是指Volume名的前缀 例如: VolumeFilter filter = new VolumeFilter(); filter.setName("my_volume_prefix"); for (Volume t : odps.volumes().iterator(filter)) { // do somthing on the Volume object }
VolumePartition VolumePartition表示ODPS中的volume partition 暂未开放，仅限内部使用
Volumes Volumes表示ODPS中所有Volume的集合 暂未开放，仅限内部使用

com.aliyun.odps.account使用的com.aliyun.odps中的类

类和说明
OdpsException ODPS SDK产生的异常

com.aliyun.odps.data使用的com.aliyun.odps中的类

类和说明
TableSchema TableSchema表示ODPS中表的定义

com.aliyun.odps.task使用的com.aliyun.odps中的类

类和说明
Instance Instance表示ODPS中计算任务的一个运行实例
Odps Odps类是ODPS SDK的入口 构造Odps对象: Account account = new AliyunAccount("my_access_id", "my_access_key"); Odps odps = new Odps(account); odps.setDefaultProject("my_project"); for (Table t : odps.tables()) { .... } 设置默认Project: SDK中很多集合类上提供的方法有两个版本，比如: odps.tables().get("table_name") odps.tables().get("project_name", "table_name") 第一个版本的函数会使用Odps对象上保存的默认Project，设置默认Project的方法如下: odps.setDefaultProject("my_project");
OdpsException ODPS SDK产生的异常
Task ODPS的Task定义
Task.Properties Task properties

com.aliyun.odps.tunnel使用的com.aliyun.odps中的类

类和说明
Odps Odps类是ODPS SDK的入口 构造Odps对象: Account account = new AliyunAccount("my_access_id", "my_access_key"); Odps odps = new Odps(account); odps.setDefaultProject("my_project"); for (Table t : odps.tables()) { .... } 设置默认Project: SDK中很多集合类上提供的方法有两个版本，比如: odps.tables().get("table_name") odps.tables().get("project_name", "table_name") 第一个版本的函数会使用Odps对象上保存的默认Project，设置默认Project的方法如下: odps.setDefaultProject("my_project");
OdpsException ODPS SDK产生的异常
TableSchema TableSchema表示ODPS中表的定义