org.springframework.data.hadoop.mapreduce

Class JobUtils

java.lang.Object

org.springframework.data.hadoop.mapreduce.JobUtils

public abstract class JobUtils
extends java.lang.Object

Utilities around Hadoop Jobs. Mainly used for converting a Job instance to different types.

Author:

Costin Leau, Mark Pollack, Thomas Risberg

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JobUtils.JobStatus Status of a job.

Constructor Summary

Constructors

Constructor and Description
JobUtils()

Method Summary

Methods

Modifier and Type	Method and Description
static org.apache.hadoop.mapred.JobConf	getJobConf(org.apache.hadoop.mapreduce.Job job)
static org.apache.hadoop.mapreduce.JobID	getJobId(org.apache.hadoop.mapreduce.Job job)
static org.apache.hadoop.mapred.JobID	getOldJobId(org.apache.hadoop.mapreduce.Job job)
static org.apache.hadoop.mapred.RunningJob	getRunningJob(org.apache.hadoop.mapreduce.Job job)
static JobUtils.JobStatus	getStatus(org.apache.hadoop.mapreduce.Job job) Returns the status of the given job.

Methods inherited from class java.lang.Object

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

Constructor Detail

JobUtils

public JobUtils()

Method Detail

getRunningJob

public static org.apache.hadoop.mapred.RunningJob getRunningJob(org.apache.hadoop.mapreduce.Job job)

getJobId

public static org.apache.hadoop.mapreduce.JobID getJobId(org.apache.hadoop.mapreduce.Job job)

getOldJobId

public static org.apache.hadoop.mapred.JobID getOldJobId(org.apache.hadoop.mapreduce.Job job)

getJobConf

public static org.apache.hadoop.mapred.JobConf getJobConf(org.apache.hadoop.mapreduce.Job job)

getStatus

public static JobUtils.JobStatus getStatus(org.apache.hadoop.mapreduce.Job job)

Returns the status of the given job. May return null indicating accessing the job caused exceptions.

Parameters:

job - the job

Returns:

the job status