public class HadoopJobExecHelper
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected JobConf |
job |
java.lang.String |
jobId |
protected int |
mapProgress |
protected int |
reduceProgress |
static java.util.Map<java.lang.String,java.lang.String> |
runningJobKillURIs
A list of the currently running jobs spawned in this Hive instance that is used to kill all
running jobs in the event of an unexpected shutdown - i.e., the JVM shuts down while there are
still jobs running.
|
protected Task<? extends java.io.Serializable> |
task |
Constructor and Description |
---|
HadoopJobExecHelper() |
HadoopJobExecHelper(JobConf job,
SessionState.LogHelper console,
Task<? extends java.io.Serializable> task,
HadoopJobExecHook hookCallBack) |
Modifier and Type | Method and Description |
---|---|
boolean |
checkFatalErrors(Counters ctrs,
java.lang.StringBuilder errMsg) |
static java.lang.String |
getJobEndMsg(java.lang.String jobId)
this msg pattern is used to track when a job is successfully done.
|
java.lang.String |
getJobId() |
void |
jobInfo(RunningJob rj)
from StreamJob.java.
|
static void |
killRunningJobs() |
void |
localJobDebugger(int exitVal,
java.lang.String taskId) |
boolean |
mapDone() |
boolean |
mapStarted() |
int |
progress(RunningJob rj,
JobClient jc) |
int |
progressLocal(java.lang.Process runningJob,
java.lang.String taskId) |
boolean |
reduceDone() |
boolean |
reduceStarted() |
void |
setJobId(java.lang.String jobId) |
protected transient JobConf job
protected Task<? extends java.io.Serializable> task
protected transient int mapProgress
protected transient int reduceProgress
public transient java.lang.String jobId
public static java.util.Map<java.lang.String,java.lang.String> runningJobKillURIs
public HadoopJobExecHelper()
public HadoopJobExecHelper(JobConf job, SessionState.LogHelper console, Task<? extends java.io.Serializable> task, HadoopJobExecHook hookCallBack)
public static java.lang.String getJobEndMsg(java.lang.String jobId)
jobId
- public boolean mapStarted()
public boolean reduceStarted()
public boolean mapDone()
public boolean reduceDone()
public java.lang.String getJobId()
public void setJobId(java.lang.String jobId)
public static void killRunningJobs()
public boolean checkFatalErrors(Counters ctrs, java.lang.StringBuilder errMsg)
public void jobInfo(RunningJob rj)
public void localJobDebugger(int exitVal, java.lang.String taskId)
public int progressLocal(java.lang.Process runningJob, java.lang.String taskId)
public int progress(RunningJob rj, JobClient jc) throws java.io.IOException
java.io.IOException
Copyright © 2012 The Apache Software Foundation