org.apache.hadoop.mapred

Class WebHCatJTShim23

java.lang.Object

org.apache.hadoop.mapred.WebHCatJTShim23

All Implemented Interfaces:

HadoopShims.WebHCatJTShim

public class WebHCatJTShim23
extends Object
implements HadoopShims.WebHCatJTShim

Constructor Summary

Constructors

Constructor and Description
WebHCatJTShim23(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) Returns all jobs tagged with the given tag that have been started after the given timestamp.
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) Kills all jobs tagged with the given tag that have been started after the given timestamp.

Methods inherited from class java.lang.Object

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

Constructor Detail

WebHCatJTShim23

public WebHCatJTShim23(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)

Kills all jobs tagged with the given tag that have been started after the given timestamp.

Specified by:

killJobs in interface HadoopShims.WebHCatJTShim

getJobs

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

Returns all jobs tagged with the given tag that have been started after the given timestamp. Returned jobIds are MapReduce JobIds.

Specified by:

getJobs in interface HadoopShims.WebHCatJTShim