org.apache.hadoop.mapred

Class WebHCatJTShim20S

java.lang.Object

org.apache.hadoop.mapred.WebHCatJTShim20S

All Implemented Interfaces:

HadoopShims.WebHCatJTShim

public class WebHCatJTShim20S
extends Object
implements HadoopShims.WebHCatJTShim

This is in org.apache.hadoop.mapred package because it relies on JobSubmissionProtocol which is package private

Constructor Summary

Constructors

Constructor and Description
WebHCatJTShim20S(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.security.UserGroupInformation ugi) Create a connection to the Job Tracker.

Method Summary

Methods

Modifier and Type	Method and Description
void	addCacheFile(URI uri, org.apache.hadoop.mapreduce.Job job) Does exactly what org.apache.hadoop.mapreduce.Job#addCacheFile(URI) in Hadoop 2.
void	close() Close the connection to the Job Tracker.
org.apache.hadoop.mapred.JobStatus[]	getAllJobs() Get all the jobs submitted.
org.apache.hadoop.mapred.JobProfile	getJobProfile(org.apache.hadoop.mapred.JobID jobid) Grab a handle to a job that is already known to the JobTracker.
Set<String>	getJobs(String tag, long timestamp) Get jobs is only supported on hadoop 2.0+.
org.apache.hadoop.mapred.JobStatus	getJobStatus(org.apache.hadoop.mapred.JobID jobid) Grab a handle to a job that is already known to the JobTracker.
void	killJob(org.apache.hadoop.mapred.JobID jobid) Kill a job.
void	killJobs(String tag, long timestamp) Kill jobs is only supported on hadoop 2.0+.

Methods inherited from class java.lang.Object

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

Constructor Detail

WebHCatJTShim20S

public WebHCatJTShim20S(org.apache.hadoop.conf.Configuration conf,
                org.apache.hadoop.security.UserGroupInformation ugi)
                 throws IOException

Create a connection to the Job Tracker.

Throws:

IOException

Method Detail

getJobProfile

public org.apache.hadoop.mapred.JobProfile getJobProfile(org.apache.hadoop.mapred.JobID jobid)
                                                  throws IOException

Grab a handle to a job that is already known to the JobTracker.

Specified by:

getJobProfile in interface HadoopShims.WebHCatJTShim

Returns:

Profile of the job, or null if not found.

Throws:

IOException

getJobStatus

public org.apache.hadoop.mapred.JobStatus getJobStatus(org.apache.hadoop.mapred.JobID jobid)
                                                throws IOException

Grab a handle to a job that is already known to the JobTracker.

Specified by:

getJobStatus in interface HadoopShims.WebHCatJTShim

Returns:

Status of the job, or null if not found.

Throws:

IOException

killJob

public void killJob(org.apache.hadoop.mapred.JobID jobid)
             throws IOException

Kill a job.

Specified by:

killJob in interface HadoopShims.WebHCatJTShim

Throws:

IOException

getAllJobs

public org.apache.hadoop.mapred.JobStatus[] getAllJobs()
                                                throws IOException

Get all the jobs submitted.

Specified by:

getAllJobs in interface HadoopShims.WebHCatJTShim

Throws:

IOException

close

public void close()

Close the connection to the Job Tracker.

Specified by:

close in interface HadoopShims.WebHCatJTShim

addCacheFile

public void addCacheFile(URI uri,
                org.apache.hadoop.mapreduce.Job job)

Description copied from interface: HadoopShims.WebHCatJTShim

Does exactly what org.apache.hadoop.mapreduce.Job#addCacheFile(URI) in Hadoop 2. Assumes that both parameters are not null.

Specified by:

addCacheFile in interface HadoopShims.WebHCatJTShim

killJobs

public void killJobs(String tag,
            long timestamp)

Kill jobs is only supported on hadoop 2.0+.

Specified by:

killJobs in interface HadoopShims.WebHCatJTShim

getJobs

public Set<String> getJobs(String tag,
                  long timestamp)

Get jobs is only supported on hadoop 2.0+.

Specified by:

getJobs in interface HadoopShims.WebHCatJTShim