org.apache.hadoop.hive.shims

Interface HadoopShims.WebHCatJTShim

All Known Implementing Classes:

WebHCatJTShim20S, WebHCatJTShim23

Enclosing interface:

HadoopShims

public static interface HadoopShims.WebHCatJTShim

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.

Method Detail

getJobProfile

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.

Returns:

Profile of the job, or null if not found.

Throws:

IOException

getJobStatus

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.

Returns:

Status of the job, or null if not found.

Throws:

IOException

killJob

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

Kill a job.

Throws:

IOException

getAllJobs

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

Get all the jobs submitted.

Throws:

IOException

close

void close()

Close the connection to the Job Tracker.

addCacheFile

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

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

killJobs

void killJobs(String tag,
            long timestamp)

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

getJobs

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.