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

static class

JobUtils.JobStatus Status of a job.

Constructor Summary

JobUtils()

Method Summary

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 -

Returns:

the job status