类的使用
com.aliyun.odps.Instance

使用Instance的程序包

程序包	说明
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.task	提供ODPS支持的Task定义

com.aliyun.odps中Instance的使用

返回Instance的com.aliyun.odps中的方法

限定符和类型	方法和说明
Instance	Instances.create(Job job) 为给定的Job定义在默认Project中创建Instance
Instance	Instances.create(String projectName, Task task) 为给定的Task创建Instance
Instance	Instances.create(String projectName, Task task, int priority) 为给定的Task创建Instance
Instance	Instances.create(String projectName, Task task, Integer priority, String runningCluster)
Instance	Instances.create(String projectName, Task task, int priority, String runningCluster) 为给定的Task创建Instance
Instance	Instances.create(Task task) 为给定的Task创建Instance
Instance	Instances.create(Task task, int priority) 为给定的Task创建Instance
Instance	Instances.create(Task task, int priority, String runningCluster) 为给定的Task创建Instance
Instance	Instances.get(String id) 获取指定Instance
Instance	Instances.get(String projectName, String id) 获取指定Instance

返回变量类型为Instance的类型的com.aliyun.odps中的方法

限定符和类型	方法和说明
Iterator<Instance>	Instances.iterator() 获得Instance的迭代器
Iterator<Instance>	Instances.iterator(InstanceFilter filter) 获得Instance迭代器
Iterator<Instance>	Instances.iterator(String project) 获得指定Project下，Instance迭代器
Iterator<Instance>	Instances.iterator(String project, InstanceFilter filter) 获得指定Project下，Instance迭代器

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

限定符和类型	方法和说明
abstract void	OdpsHook.after(Instance instance, Odps odps) instance 结束后，框架会将 Instance 和 odps 对象传入 hook
void	OdpsHooks.after(Instance instance, Odps odps) 调用 Hook 的 after
String	LogView.generateLogView(Instance instance, long hours)
void	OdpsHook.onInstanceCreated(Instance instance, Odps odps) 向远程提交 job 并产生 instance 时，将 Instance 和 Odps 对象传入 Hook
void	OdpsHooks.onInstanceCreated(Instance instance, Odps odps) 调用 Hook 的 ready

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

返回Instance的com.aliyun.odps.task中的方法

限定符和类型	方法和说明
static Instance	SQLTask.run(Odps odps, String sql) 运行 SQL.
static Instance	SQLCostTask.run(Odps odps, String sql) 通过匿名Instance运行SQLCostTask
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	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	MoyeTask.run(Odps odps, String project, String plan, Map<String,String> hints, int priority)
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)

参数类型为Instance的com.aliyun.odps.task中的方法

限定符和类型	方法和说明
static List<Record>	SQLTask.getResult(Instance instance) Columns of each record in result are ALL OdpsType.STIRNG, ignore their real type in odps Return value is valid only when SQL query is select, otherwise, result will be empty.
static List<Record>	SQLTask.getResult(Instance instance, String taskName) Columns of each record in result are ALL OdpsType.STIRNG, ignore their real type in odps Return value is valid only when SQL query is select, otherwise, result will be empty.