类 com.aliyun.odps.OdpsException
的使用

使用OdpsException的程序包

程序包	说明
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.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中OdpsException的使用

com.aliyun.odps中OdpsException的子类

限定符和类型	类和说明
class	NoSuchObjectException ODPS对象不存在

抛出OdpsException的com.aliyun.odps中的方法

限定符和类型	方法和说明
void	OdpsHooks.after(Instance instance, Odps odps) 调用 Hook 的 after
abstract void	OdpsHook.after(Instance instance, Odps odps) instance 结束后，框架会将 Instance 和 odps 对象传入 hook
void	OdpsHooks.before(Job job, Odps odps) 调用 Hook 的 before
abstract void	OdpsHook.before(Job job, Odps odps) 提交代码前，框架会将 Job 和 Odps 对象传入 Hook
void	Resources.create(FileResource r, InputStream in) 创建文件资源
void	Functions.create(Function func) 创建函数
Instance	Instances.create(Job job) 为给定的Job定义在默认Project中创建Instance
void	Resources.create(String projectName, FileResource r, InputStream in) 创建文件资源
void	Functions.create(String projectName, Function func) 创建函数
void	Topologies.create(String topologyName, String description) 创建Topology
void	Volumes.create(String volumeName, String comment) 创建Volume
String	StreamJobs.create(String streamJobName, String sql, Map<String,String> hints) 创建StreamJob
void	Topologies.create(String projectName, String topologyName, String description) 创建Topology
void	Volumes.create(String projectName, String volumeName, String comment) 创建Volume
String	StreamJobs.create(String projectName, String streamJobName, String sql, Map<String,String> hints) 创建StreamJob
void	Tables.create(String projectName, String tableName, TableSchema schema) 创建表
void	Tables.create(String projectName, String tableName, TableSchema schema, boolean ifNotExists) 创建表
void	Resources.create(String projectName, TableResource r) 创建表资源
void	Tables.create(String tableName, TableSchema schema) 创建表
void	Tables.create(String tableName, TableSchema schema, boolean ifNotExists) 创建表
Instance	Instances.create(String projectName, Task task) 为给定的Task创建Instance
Instance	Instances.create(String projectName, Task task, int priority) 为给定的Task创建Instance
void	Resources.create(TableResource r) 创建表资源
Instance	Instances.create(Task task) 为给定的Task创建Instance
Instance	Instances.create(Task task, int priority) 为给定的Task创建Instance
void	Table.createPartition(PartitionSpec spec) 增加分区
void	Table.createPartition(PartitionSpec spec, boolean ifNotExists) 增加分区
void	Table.createShards(long shardCount) 在Table上创建Shards
void	Table.createShards(long shardCount, boolean enableHubTable, long hubLifeCycle) 在HubTable上创建Shards,只能在HubTable上创建Shard,并且当前一个HubTable只能创建一次Shard,否则抛出OdpsException
FileResource	Resources.createTempResource(String fileName) 上传临时文件资源
FileResource	Resources.createTempResource(String projectName, String fileName) 上传临时文件资源
FileResource	Resources.createTempResource(String projectName, String fileName, Resource.Type type)
void	Tables.delete(String tableName) 删除表
void	Functions.delete(String name) 删除函数
String	StreamJobs.delete(String streamJobName) 删除StreamJob
void	Topologies.delete(String topologyName) 删除Topology
void	Resources.delete(String name) 删除资源
void	Volumes.delete(String volumeName) 删除Volume
void	Tables.delete(String tableName, boolean ifExists) 删除表
void	Tables.delete(String projectName, String tableName) 删除表
void	Functions.delete(String projectName, String name) 删除函数
String	StreamJobs.delete(String projectName, String streamJobName) 删除StreamJob
void	Topologies.delete(String projectName, String topologyName) 删除Topology
void	Resources.delete(String projectName, String name) 删除资源
void	Volumes.delete(String projectName, String volumeName) 删除Volume
void	Tables.delete(String projectName, String tableName, boolean ifExists) 删除表
void	Table.deletePartition(PartitionSpec spec) 删除指定分区
void	Table.deletePartition(PartitionSpec spec, boolean ifExists) 删除指定分区
void	Volume.deleteVolumePartition(String partitionName) 删除指定分区
boolean	Projects.exists(String projectName) 检查Project是否存在
boolean	Tables.exists(String tableName) 判断指定表是否存在
boolean	Instances.exists(String id) 判断指定 Instance 是否存在
boolean	Resources.exists(String resourceName) 判断指定资源是否存在
boolean	Volumes.exists(String volumeName) 判断指定Volume是否存在
boolean	Tables.exists(String projectName, String tableName) 判断指定表是否存在
boolean	Instances.exists(String projectName, String id) 判断指定 Instance 是否存在
boolean	Resources.exists(String projectName, String resourceName) 判断指定资源是否存在
boolean	Volumes.exists(String projectName, String volumeName) 判断指定Volume是否存在
Project	Projects.get() 获得默认Project对象
Project	Projects.get(String projectName) 获取指定Project
Map<String,String>	Project.getExtendedProperties() 获取 Project 扩展配置信息
String	Instance.getLog(String workerId, LogType logType, int size) 获取Worker运行的LOG内容
int	Instance.getPriority() 获取 Instance 的优先级
InputStream	Resources.getResourceAsStream(String name) 获得资源文件的字节流
InputStream	Resources.getResourceAsStream(String projectName, String name) 获得资源文件的字节流
String	StreamJobs.getStatus(String streamJobName) 获取StreamJob的状态
String	StreamJobs.getStatus(String projectName, String streamJobName) 获取StreamJob的状态
String	Instance.getTaskDetailJson(String taskName)
String	Instance.getTaskDetailJson2(String taskName)
Set<String>	Instance.getTaskNames() 获得Instance所包含的所有Task的名称
List<Instance.StageProgress>	Instance.getTaskProgress(String taskName) 查询指定Task的Stage进度
Map<String,String>	Instance.getTaskResults() 获得Instance中Task的运行结果
Map<String,Instance.Result>	Instance.getTaskResultsWithFormat() 获得Instance中Task的运行结果
List<Task>	Instance.getTasks() 返回与作业运行实例相关的作业Task实例。
Map<String,Instance.TaskStatus>	Instance.getTaskStatus() 查询Instance中所有Task的执行状态
Instance.TaskSummary	Instance.getTaskSummary(String taskName) 获得Instance中Task的运行汇总信息 当 Server 端返回信息，但是信息格式错误时，返回 null
boolean	Table.hasPartition(PartitionSpec spec) 判断指定分区是否存在
boolean	Instance.isSuccessful() 检查Instance是否执行成功 成功的含义为Instance执行结束,并且所有Task的状态为成功
String	StreamJobs.list()
String	StreamJobs.pause(String streamJobName) 暂停StreamJob
String	StreamJobs.pause(String projectName, String streamJobName) 暂停StreamJob
RecordReader	Table.read(int limit) 读取表内的数据
RecordReader	Table.read(PartitionSpec partition, List<String> columns, int limit) 读取表内的数据 读取数据时，最多返回 1W 条记录，若超过，数据将被截断。
String	StreamJobs.rebalance(String streamJobName, Map<String,String> hints) Rebalance StreamJob
String	StreamJobs.rebalance(String projectName, String streamJobName, Map<String,String> hints) Rebalance StreamJob
void	Table.reload()
void	VolumePartition.reload()
void	Resource.reload()
abstract void	LazyLoad.reload() 重新加载属性值
void	Volume.reload()
void	Partition.reload()
void	Project.reload()
void	Instance.reload()
void	Function.reload()
void	Topology.reload()
String	StreamJobs.resume(String streamJobName, Map<String,String> hints) 恢复StreamJob
String	StreamJobs.resume(String projectName, String streamJobName, Map<String,String> hints) 恢复StreamJob
void	Instance.stop() 停止正在执行的Instance
String	Job.toXmlString()
void	Table.truncate() 删除表数据
void	Resources.update(FileResource r, InputStream in) 更新文件资源
void	Resources.update(String projectName, FileResource r, InputStream in) 更新文件资源
void	Resources.update(String projectName, TableResource r) 更新表资源
void	Resources.update(TableResource r) 更新表资源
void	Instance.waitForSuccess() 阻塞当前线程, 直到Instance结束
void	Instance.waitForSuccess(long interval) 阻塞当前线程, 直到Instance结束

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

参数类型为OdpsException的com.aliyun.odps.account中的方法

限定符和类型	方法和说明
boolean	DomainAccount.shouldRefreshToken(OdpsException e)

抛出OdpsException的com.aliyun.odps.account中的方法

限定符和类型	方法和说明
static DomainAccount	DomainAccount.getAccountByUsername(String username, String password)
static String[]	AuthorizationUtil.getDomainAccessAndRefreshToken(String username, String password) 需要经过两次请求才能获取Domain token，此为第二次请求 新token不会覆盖老token,token只和自己的生存周期有关
static String	AuthorizationUtil.getTaobaoToken(String username, String password) 采用用户名和密码获取token,无需刷新，新token不会覆盖老token,token只和自己的生存周期有关
static void	AuthorizationUtil.refreshDomainToken(String accessToken, String refreshToken) 刷新域账户accessToken 成功直接返回，原有accessToken 将延长有效期3天，失败抛出异常
void	DomainAccount.refreshToken()

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

抛出OdpsException的com.aliyun.odps.task中的方法

限定符和类型	方法和说明
static Instance	SQLCostTask.run(Odps odps, String sql) 通过匿名Instance运行SQLCostTask
static Instance	SQLTask.run(Odps odps, String sql) 运行 SQL.
static Instance	LOTTask.run(Odps odps, String input, boolean runSQL) 通过匿名Instance运行LOTTask
static Instance	GraphTask.run(Odps odps, String project, GraphTask graphTask)
static Instance	GraphTask.run(Odps odps, String project, GraphTask graphTask, int priority)
static Instance	MoyeTask.run(Odps odps, String project, String plan)
static Instance	LOTTask.run(Odps odps, String project, String input, boolean runSQL, Map<String,String> hints, Map<String,String> aliases) 通过匿名Instance运行LOTTask
static Instance	LOTTask.run(Odps odps, String project, String input, boolean runSQL, String taskName, Map<String,String> hints, Map<String,String> aliases) 运行LOTTask
static Instance	MoyeTask.run(Odps odps, String project, String plan, Map<String,String> hints)
static Instance	SQLCostTask.run(Odps odps, String project, String sql, Map<String,String> hints) 通过匿名Instance运行SQLCostTask
static Instance	SQLTask.run(Odps odps, String project, String sql, Map<String,String> hints, Map<String,String> aliases) 运行SQL
static Instance	SQLCostTask.run(Odps odps, String project, String sql, String taskName, Map<String,String> hints) 运行SQLCostTask
static Instance	SQLTask.run(Odps odps, String project, String sql, String taskName, Map<String,String> hints, Map<String,String> aliases)
static Instance	SQLTask.run(Odps odps, String project, String sql, String taskName, Map<String,String> hints, Map<String,String> aliases, int priority)

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

com.aliyun.odps.tunnel中OdpsException的子类

限定符和类型	类和说明
class	InvalidColumnTypeException 该异常在Schema的中列类型不被支持时抛出
class	InvalidRecordSchema 该异常在Schema的格式不正确的时候抛出
class	TunnelException 该异常在DataTunnel服务访问失败时抛出。