程序包 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()); }

请参阅: 说明

类概要

类	说明
ArchiveResource	ArchiveResource表示ODPS中一个Archive类型资源。
FileResource	FileResource表示ODPS中一个文件类型资源
Function	Function表示ODPS中的函数
Functions	表示ODPS内所有Function的集合
Instance	Instance表示ODPS中计算任务的一个运行实例
Instance.Result
Instance.StageProgress	StageProgress表示Task执行过程中各阶段的进度统计
Instance.TaskStatus	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的集合
JarResource	JarResource表示ODPS中一个JAR类型的资源
Job	ODPS Job定义。
LazyLoad	LazyLoad表示此类型的属性值可能是延迟加载的 延迟加载的含义是, 对象的属性值可能不存在，在调用gets等方法时视需要通过RESTful API从服务器断获取
ListIterator<E>	支持通过ListIterator.list()自定义的Iterator
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");
OdpsHook	OdpsHook 对象，用于在提交作业前后插入代码
OdpsHooks	OdpsHooks 类 注册 OdpsHook 类 用于在启动 Instance 前后分别运行插件代码 一个 OdpsHooks 实例针对一个 Instance， 包含了一组实例化的 OdpsHook 对象
Partition	Partition类的对象表示ODPS分区表中一个特定的分区
Project	ODPS项目空间
Project.Cluster
Projects	Projects表示ODPS中所有Project的集合
PyResource	PyResource表示ODPS中一个python类型资源
Resource	Resource表示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的集合 暂未开放，仅限内部使用
XmlPropertyMapAdapter

枚举概要

枚举	说明
Instance.Status	Instance的运行状态。
Instance.TaskStatus.Status	Instance中Task的状态
LogType	日志类型。
Project.Status	项目空间状态
Resource.Type	表示ODPS中资源的类型

异常错误概要

异常错误	说明
NoSuchObjectException	ODPS对象不存在
OdpsException	ODPS SDK产生的异常
ReloadException	重新加载异常，当LazyLoad对象实际加载对象属性时， 如果遇到网络等异常状况，可能抛出此异常

程序包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());
   }