public class Instance extends LazyLoad
| 限定符和类型 | 类和说明 |
|---|---|
static class |
Instance.Result |
static class |
Instance.StageProgress
StageProgress表示
Task执行过程中各阶段的进度统计 |
static class |
Instance.Status
Instance的运行状态。
|
static class |
Instance.TaskStatus
Task执行状态
|
static class |
Instance.TaskSummary
TaskSummary包含
Task运行结束后的汇总信息
Summary信息以key-value对的形式组织
|
| 限定符和类型 | 方法和说明 |
|---|---|
Date |
getEndTime()
获得Instance结束执行时间
|
String |
getId()
获得Instance的ID
|
String |
getLog(String workerId,
LogType logType,
int size)
获取Worker运行的LOG内容
|
OdpsHooks |
getOdpsHooks() |
String |
getOwner()
获得Instance所属用户
|
int |
getPriority()
获取 Instance 的优先级
|
String |
getProject()
获得Instance所属
Project名称 |
Date |
getStartTime()
获得Instance开始执行时间
|
Instance.Status |
getStatus()
获得Instance状态
Instance状态如下:
RUNNING: 正在执行 SUSPENDED: 被挂起 TERMINATED: 执行结束, 包括成功、失败、取消等 |
String |
getTaskDetailJson(String taskName) |
String |
getTaskDetailJson2(String taskName) |
Set<String> |
getTaskNames()
获得Instance所包含的所有
Task的名称 |
List<Instance.StageProgress> |
getTaskProgress(String taskName)
查询指定Task的Stage进度
|
Map<String,String> |
getTaskResults()
获得Instance中Task的运行结果
|
Map<String,Instance.Result> |
getTaskResultsWithFormat()
获得Instance中
Task的运行结果 |
List<Task> |
getTasks()
返回与作业运行实例相关的作业
Task实例。 |
Map<String,Instance.TaskStatus> |
getTaskStatus()
查询Instance中所有
Task的执行状态 |
Instance.TaskSummary |
getTaskSummary(String taskName)
获得Instance中Task的运行汇总信息 当 Server 端返回信息,但是信息格式错误时,返回 null
|
boolean |
isHookInvoked() |
boolean |
isSuccessful()
检查
Instance是否执行成功
成功的含义为Instance执行结束,并且所有Task的状态为成功
|
boolean |
isSync()
获得Instance是否为同步执行
|
boolean |
isTerminated()
检查是否执行完成
|
void |
reload()
重新加载属性值
|
void |
setHookInvoked(boolean hookInvoked) |
void |
setOdpsHooks(OdpsHooks hooks) |
void |
stop()
停止正在执行的Instance
|
void |
waitForSuccess()
阻塞当前线程, 直到Instance结束
|
void |
waitForSuccess(long interval)
阻塞当前线程, 直到Instance结束
|
public void reload()
throws OdpsException
LazyLoadreload 在类中 LazyLoadOdpsExceptionpublic void stop()
throws OdpsException
OdpsExceptionpublic Map<String,Instance.Result> getTaskResultsWithFormat() throws OdpsException
Task的运行结果Task的运行结果, key为Task的名称,value为Instance.ResultOdpsExceptionpublic Map<String,String> getTaskResults() throws OdpsException
Task的运行结果, key为Task的名称,value为Instance.Result
.getString()的结果。OdpsExceptionpublic Instance.TaskSummary getTaskSummary(String taskName) throws OdpsException
taskName - 指定的TaskNameInstance.TaskSummaryOdpsExceptionpublic Map<String,Instance.TaskStatus> getTaskStatus() throws OdpsException
Task的执行状态Instance.TaskStatus对象OdpsExceptionpublic Set<String> getTaskNames() throws OdpsException
Task的名称Task的名称集合OdpsExceptionpublic boolean isSuccessful()
throws OdpsException
Instance是否执行成功
成功的含义为Instance执行结束,并且所有Task的状态为成功
OdpsExceptionpublic void waitForSuccess()
throws OdpsException
OdpsException - Instance失败public void waitForSuccess(long interval)
throws OdpsException
interval - 内部轮询间隔OdpsException - Instance失败public List<Instance.StageProgress> getTaskProgress(String taskName) throws OdpsException
taskName - Task名称Instance.StageProgress列表OdpsExceptionpublic String getId()
public Instance.Status getStatus()
Instance状态如下:
Status.TERMINATEDpublic boolean isTerminated()
public boolean isSync()
public String getOwner()
public Date getStartTime()
public Date getEndTime()
public List<Task> getTasks() throws OdpsException
Task实例。Task实例。OdpsExceptionpublic int getPriority()
throws OdpsException
OdpsExceptionpublic String getLog(String workerId, LogType logType, int size) throws OdpsException
workerId - Worker ID,Task 内Worker的唯一标示。logType - LogType 对象size - 展示Log内容的长度OdpsExceptionIOExceptionpublic String getTaskDetailJson(String taskName) throws OdpsException
OdpsExceptionpublic OdpsHooks getOdpsHooks()
public void setOdpsHooks(OdpsHooks hooks)
public boolean isHookInvoked()
public void setHookInvoked(boolean hookInvoked)
public String getTaskDetailJson2(String taskName) throws OdpsException
OdpsExceptionCopyright © 2015 Alibaba Cloud Computing. All rights reserved.