org.apache.hadoop.mapred

クラス JobStatus

java.lang.Object

org.apache.hadoop.mapreduce.JobStatus

org.apache.hadoop.mapred.JobStatus

すべての実装されたインタフェース:

Cloneable, Writable

@InterfaceAudience.Public
 @InterfaceStability.Stable
public class JobStatus
extends JobStatus

Describes the current status of a job. This is not intended to be a comprehensive piece of data. For that, look at JobProfile.

フィールドのサマリー

フィールド

修飾子とタイプ	フィールドと説明
static int	FAILED
static int	KILLED
static int	PREP
static int	RUNNING
static int	SUCCEEDED

コンストラクタのサマリー

コンストラクタ

コンストラクタと説明
JobStatus()
JobStatus(JobID jobid, float setupProgress, float mapProgress, float reduceProgress, float cleanupProgress, int runState, JobPriority jp) 非推奨です。
JobStatus(JobID jobid, float setupProgress, float mapProgress, float reduceProgress, float cleanupProgress, int runState, JobPriority jp, String user, String jobName, String jobFile, String trackingUrl) Create a job status object for a given jobid.
JobStatus(JobID jobid, float setupProgress, float mapProgress, float reduceProgress, float cleanupProgress, int runState, JobPriority jp, String user, String jobName, String jobFile, String trackingUrl, boolean isUber) Create a job status object for a given jobid.
JobStatus(JobID jobid, float setupProgress, float mapProgress, float reduceProgress, float cleanupProgress, int runState, JobPriority jp, String user, String jobName, String jobFile, String trackingUrl, boolean isUber, String historyFile) Create a job status object for a given jobid.
JobStatus(JobID jobid, float setupProgress, float mapProgress, float reduceProgress, float cleanupProgress, int runState, JobPriority jp, String user, String jobName, String queue, String jobFile, String trackingUrl) Create a job status object for a given jobid.
JobStatus(JobID jobid, float setupProgress, float mapProgress, float reduceProgress, float cleanupProgress, int runState, JobPriority jp, String user, String jobName, String queue, String jobFile, String trackingUrl, boolean isUber) Create a job status object for a given jobid.
JobStatus(JobID jobid, float setupProgress, float mapProgress, float reduceProgress, float cleanupProgress, int runState, JobPriority jp, String user, String jobName, String queue, String jobFile, String trackingUrl, boolean isUber, String historyFile) Create a job status object for a given jobid.
JobStatus(JobID jobid, float mapProgress, float reduceProgress, float cleanupProgress, int runState) 非推奨です。
JobStatus(JobID jobid, float mapProgress, float reduceProgress, float cleanupProgress, int runState, JobPriority jp) 非推奨です。
JobStatus(JobID jobid, float mapProgress, float reduceProgress, float cleanupProgress, int runState, JobPriority jp, String user, String jobName, String jobFile, String trackingUrl) Create a job status object for a given jobid.
JobStatus(JobID jobid, float mapProgress, float reduceProgress, float cleanupProgress, int runState, String user, String jobName, String jobFile, String trackingUrl) Create a job status object for a given jobid.
JobStatus(JobID jobid, float mapProgress, float reduceProgress, int runState) 非推奨です。
JobStatus(JobID jobid, float mapProgress, float reduceProgress, int runState, String user, String jobName, String jobFile, String trackingUrl) Create a job status object for a given jobid.

メソッドのサマリー

修飾子とタイプ	メソッドと説明
float	cleanupProgress()
static JobStatus	downgrade(JobStatus stat)
String	getJobId() 非推奨です。 use getJobID instead
JobID	getJobID()
JobPriority	getJobPriority() Return the priority of the job
static String	getJobRunState(int state) Helper method to get human-readable state of the job.
int	getRunState()
float	mapProgress()
float	reduceProgress()
protected void	setCleanupProgress(float p) Sets the cleanup progress of this job
void	setFailureInfo(String failureInfo) Set diagnostic information.
protected void	setFinishTime(long finishTime) Set the finish time of the job
protected void	setHistoryFile(String historyFile) Set the job history file url for a completed job
protected void	setJobACLs(Map<org.apache.hadoop.mapreduce.JobACL,AccessControlList> acls) Set the job acls.
void	setJobPriority(JobPriority jp) Set the priority of the job, defaulting to NORMAL.
protected void	setMapProgress(float p) Sets the map progress of this job
protected void	setReduceProgress(float p) Sets the reduce progress of this Job
protected void	setRetired() Set the job retire flag to true.
protected void	setSetupProgress(float p) Sets the setup progress of this job
protected void	setStartTime(long startTime) Set the start time of the job
protected void	setTrackingUrl(String trackingUrl) Set the link to the web-ui for details of the job.
float	setupProgress()
protected void	setUsername(String userName)

クラスから継承されたメソッド org.apache.hadoop.mapreduce.JobStatus

clone, getCleanupProgress, getFailureInfo, getFinishTime, getHistoryFile, getJobACLs, getJobFile, getJobName, getMapProgress, getNeededMem, getNumReservedSlots, getNumUsedSlots, getPriority, getQueue, getReduceProgress, getReservedMem, getSchedulingInfo, getSetupProgress, getStartTime, getState, getTrackingUrl, getUsedMem, getUsername, isJobComplete, isRetired, isUber, readFields, setNeededMem, setNumReservedSlots, setNumUsedSlots, setPriority, setQueue, setReservedMem, setSchedulingInfo, setState, setUber, setUsedMem, toString, write

クラスから継承されたメソッド java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

フィールドの詳細

RUNNING

public static final int RUNNING

SUCCEEDED

public static final int SUCCEEDED

FAILED

public static final int FAILED

PREP

public static final int PREP

KILLED

public static final int KILLED

コンストラクタの詳細

JobStatus

public JobStatus()

JobStatus

@Deprecated
public JobStatus(JobID jobid,
                             float mapProgress,
                             float reduceProgress,
                             float cleanupProgress,
                             int runState)

非推奨です。

JobStatus

@Deprecated
public JobStatus(JobID jobid,
                             float mapProgress,
                             float reduceProgress,
                             int runState)

非推奨です。

Create a job status object for a given jobid.

パラメータ:

jobid - The jobid of the job

mapProgress - The progress made on the maps

reduceProgress - The progress made on the reduces

runState - The current state of the job

JobStatus

@Deprecated
public JobStatus(JobID jobid,
                             float mapProgress,
                             float reduceProgress,
                             float cleanupProgress,
                             int runState,
                             JobPriority jp)

非推奨です。

Create a job status object for a given jobid.

パラメータ:

jobid - The jobid of the job

mapProgress - The progress made on the maps

reduceProgress - The progress made on the reduces

runState - The current state of the job

jp - Priority of the job.

JobStatus

@Deprecated
public JobStatus(JobID jobid,
                             float setupProgress,
                             float mapProgress,
                             float reduceProgress,
                             float cleanupProgress,
                             int runState,
                             JobPriority jp)

非推奨です。

Create a job status object for a given jobid.

パラメータ:

jobid - The jobid of the job

setupProgress - The progress made on the setup

mapProgress - The progress made on the maps

reduceProgress - The progress made on the reduces

cleanupProgress - The progress made on the cleanup

runState - The current state of the job

jp - Priority of the job.

JobStatus

public JobStatus(JobID jobid,
                 float mapProgress,
                 float reduceProgress,
                 float cleanupProgress,
                 int runState,
                 String user,
                 String jobName,
                 String jobFile,
                 String trackingUrl)

Create a job status object for a given jobid.

パラメータ:

jobid - The jobid of the job

mapProgress - The progress made on the maps

reduceProgress - The progress made on the reduces

cleanupProgress - The progress made on cleanup

runState - The current state of the job

user - userid of the person who submitted the job.

jobName - user-specified job name.

jobFile - job configuration file.

trackingUrl - link to the web-ui for details of the job.

JobStatus

public JobStatus(JobID jobid,
                 float mapProgress,
                 float reduceProgress,
                 int runState,
                 String user,
                 String jobName,
                 String jobFile,
                 String trackingUrl)

Create a job status object for a given jobid.

パラメータ:

jobid - The jobid of the job

mapProgress - The progress made on the maps

reduceProgress - The progress made on the reduces

runState - The current state of the job

user - userid of the person who submitted the job.

jobName - user-specified job name.

jobFile - job configuration file.

trackingUrl - link to the web-ui for details of the job.

JobStatus

public JobStatus(JobID jobid,
                 float mapProgress,
                 float reduceProgress,
                 float cleanupProgress,
                 int runState,
                 JobPriority jp,
                 String user,
                 String jobName,
                 String jobFile,
                 String trackingUrl)

Create a job status object for a given jobid.

パラメータ:

jobid - The jobid of the job

mapProgress - The progress made on the maps

reduceProgress - The progress made on the reduces

runState - The current state of the job

jp - Priority of the job.

user - userid of the person who submitted the job.

jobName - user-specified job name.

jobFile - job configuration file.

trackingUrl - link to the web-ui for details of the job.

JobStatus

public JobStatus(JobID jobid,
                 float setupProgress,
                 float mapProgress,
                 float reduceProgress,
                 float cleanupProgress,
                 int runState,
                 JobPriority jp,
                 String user,
                 String jobName,
                 String jobFile,
                 String trackingUrl)

Create a job status object for a given jobid.

パラメータ:

jobid - The jobid of the job

setupProgress - The progress made on the setup

mapProgress - The progress made on the maps

reduceProgress - The progress made on the reduces

cleanupProgress - The progress made on the cleanup

runState - The current state of the job

jp - Priority of the job.

user - userid of the person who submitted the job.

jobName - user-specified job name.

jobFile - job configuration file.

trackingUrl - link to the web-ui for details of the job.

JobStatus

public JobStatus(JobID jobid,
                 float setupProgress,
                 float mapProgress,
                 float reduceProgress,
                 float cleanupProgress,
                 int runState,
                 JobPriority jp,
                 String user,
                 String jobName,
                 String jobFile,
                 String trackingUrl,
                 boolean isUber)

Create a job status object for a given jobid.

パラメータ:

jobid - The jobid of the job

setupProgress - The progress made on the setup

mapProgress - The progress made on the maps

reduceProgress - The progress made on the reduces

cleanupProgress - The progress made on the cleanup

runState - The current state of the job

jp - Priority of the job.

user - userid of the person who submitted the job.

jobName - user-specified job name.

jobFile - job configuration file.

trackingUrl - link to the web-ui for details of the job.

isUber - Whether job running in uber mode

JobStatus

public JobStatus(JobID jobid,
                 float setupProgress,
                 float mapProgress,
                 float reduceProgress,
                 float cleanupProgress,
                 int runState,
                 JobPriority jp,
                 String user,
                 String jobName,
                 String jobFile,
                 String trackingUrl,
                 boolean isUber,
                 String historyFile)

Create a job status object for a given jobid.

パラメータ:

jobid - The jobid of the job

setupProgress - The progress made on the setup

mapProgress - The progress made on the maps

reduceProgress - The progress made on the reduces

cleanupProgress - The progress made on the cleanup

runState - The current state of the job

jp - Priority of the job.

user - userid of the person who submitted the job.

jobName - user-specified job name.

jobFile - job configuration file.

trackingUrl - link to the web-ui for details of the job.

isUber - Whether job running in uber mode

historyFile - history file

JobStatus

public JobStatus(JobID jobid,
                 float setupProgress,
                 float mapProgress,
                 float reduceProgress,
                 float cleanupProgress,
                 int runState,
                 JobPriority jp,
                 String user,
                 String jobName,
                 String queue,
                 String jobFile,
                 String trackingUrl)

Create a job status object for a given jobid.

パラメータ:

jobid - The jobid of the job

setupProgress - The progress made on the setup

mapProgress - The progress made on the maps

reduceProgress - The progress made on the reduces

cleanupProgress - The progress made on the cleanup

runState - The current state of the job

jp - Priority of the job.

user - userid of the person who submitted the job.

jobName - user-specified job name.

queue - job queue name.

jobFile - job configuration file.

trackingUrl - link to the web-ui for details of the job.

JobStatus

public JobStatus(JobID jobid,
                 float setupProgress,
                 float mapProgress,
                 float reduceProgress,
                 float cleanupProgress,
                 int runState,
                 JobPriority jp,
                 String user,
                 String jobName,
                 String queue,
                 String jobFile,
                 String trackingUrl,
                 boolean isUber)

Create a job status object for a given jobid.

パラメータ:

jobid - The jobid of the job

setupProgress - The progress made on the setup

mapProgress - The progress made on the maps

reduceProgress - The progress made on the reduces

cleanupProgress - The progress made on the cleanup

runState - The current state of the job

jp - Priority of the job.

user - userid of the person who submitted the job.

jobName - user-specified job name.

queue - job queue name.

jobFile - job configuration file.

trackingUrl - link to the web-ui for details of the job.

isUber - Whether job running in uber mode

JobStatus

public JobStatus(JobID jobid,
                 float setupProgress,
                 float mapProgress,
                 float reduceProgress,
                 float cleanupProgress,
                 int runState,
                 JobPriority jp,
                 String user,
                 String jobName,
                 String queue,
                 String jobFile,
                 String trackingUrl,
                 boolean isUber,
                 String historyFile)

Create a job status object for a given jobid.

パラメータ:

jobid - The jobid of the job

setupProgress - The progress made on the setup

mapProgress - The progress made on the maps

reduceProgress - The progress made on the reduces

cleanupProgress - The progress made on the cleanup

runState - The current state of the job

jp - Priority of the job.

user - userid of the person who submitted the job.

jobName - user-specified job name.

queue - job queue name.

jobFile - job configuration file.

trackingUrl - link to the web-ui for details of the job.

isUber - Whether job running in uber mode

historyFile - history file

メソッドの詳細

getJobRunState

public static String getJobRunState(int state)

Helper method to get human-readable state of the job.

パラメータ:

state - job state

戻り値:

human-readable state of the job

downgrade

public static JobStatus downgrade(JobStatus stat)

getJobId

@Deprecated
public String getJobId()

非推奨です。 use getJobID instead

getJobID

public JobID getJobID()

オーバーライド:

getJobID クラス内 JobStatus

戻り値:

The jobid of the Job

getJobPriority

public JobPriority getJobPriority()

Return the priority of the job

戻り値:

job priority

setMapProgress

protected void setMapProgress(float p)

Sets the map progress of this job

オーバーライド:

setMapProgress クラス内 JobStatus

パラメータ:

p - The value of map progress to set to

setCleanupProgress

protected void setCleanupProgress(float p)

Sets the cleanup progress of this job

オーバーライド:

setCleanupProgress クラス内 JobStatus

パラメータ:

p - The value of cleanup progress to set to

setSetupProgress

protected void setSetupProgress(float p)

Sets the setup progress of this job

オーバーライド:

setSetupProgress クラス内 JobStatus

パラメータ:

p - The value of setup progress to set to

setReduceProgress

protected void setReduceProgress(float p)

Sets the reduce progress of this Job

オーバーライド:

setReduceProgress クラス内 JobStatus

パラメータ:

p - The value of reduce progress to set to

setFinishTime

protected void setFinishTime(long finishTime)

Set the finish time of the job

オーバーライド:

setFinishTime クラス内 JobStatus

パラメータ:

finishTime - The finishTime of the job

setHistoryFile

protected void setHistoryFile(String historyFile)

Set the job history file url for a completed job

オーバーライド:

setHistoryFile クラス内 JobStatus

setTrackingUrl

protected void setTrackingUrl(String trackingUrl)

Set the link to the web-ui for details of the job.

オーバーライド:

setTrackingUrl クラス内 JobStatus

setRetired

protected void setRetired()

Set the job retire flag to true.

オーバーライド:

setRetired クラス内 JobStatus

getRunState

public int getRunState()

戻り値:

running state of the job

setStartTime

protected void setStartTime(long startTime)

Set the start time of the job

オーバーライド:

setStartTime クラス内 JobStatus

パラメータ:

startTime - The startTime of the job

setUsername

protected void setUsername(String userName)

オーバーライド:

setUsername クラス内 JobStatus

パラメータ:

userName - The username of the job

setJobACLs

protected void setJobACLs(Map<org.apache.hadoop.mapreduce.JobACL,AccessControlList> acls)

クラスからコピーされた説明: JobStatus

Set the job acls.

オーバーライド:

setJobACLs クラス内 JobStatus

パラメータ:

acls - Map from JobACL to AccessControlList

setFailureInfo

public void setFailureInfo(String failureInfo)

クラスからコピーされた説明: JobStatus

Set diagnostic information.

オーバーライド:

setFailureInfo クラス内 JobStatus

パラメータ:

failureInfo - diagnostic information

setJobPriority

public void setJobPriority(JobPriority jp)

Set the priority of the job, defaulting to NORMAL.

パラメータ:

jp - new job priority

mapProgress

public float mapProgress()

戻り値:

Percentage of progress in maps

cleanupProgress

public float cleanupProgress()

戻り値:

Percentage of progress in cleanup

setupProgress

public float setupProgress()

戻り値:

Percentage of progress in setup

reduceProgress

public float reduceProgress()

戻り値:

Percentage of progress in reduce