public class WebHCatJTShim23 extends Object implements HadoopShims.WebHCatJTShim
Constructor and Description |
---|
WebHCatJTShim23(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.security.UserGroupInformation ugi)
Create a connection to the Job Tracker.
|
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.
|
public WebHCatJTShim23(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.security.UserGroupInformation ugi) throws IOException
IOException
public org.apache.hadoop.mapred.JobProfile getJobProfile(org.apache.hadoop.mapred.JobID jobid) throws IOException
getJobProfile
in interface HadoopShims.WebHCatJTShim
IOException
public org.apache.hadoop.mapred.JobStatus getJobStatus(org.apache.hadoop.mapred.JobID jobid) throws IOException
getJobStatus
in interface HadoopShims.WebHCatJTShim
IOException
public void killJob(org.apache.hadoop.mapred.JobID jobid) throws IOException
killJob
in interface HadoopShims.WebHCatJTShim
IOException
public org.apache.hadoop.mapred.JobStatus[] getAllJobs() throws IOException
getAllJobs
in interface HadoopShims.WebHCatJTShim
IOException
public void close()
close
in interface HadoopShims.WebHCatJTShim
public void addCacheFile(URI uri, org.apache.hadoop.mapreduce.Job job)
HadoopShims.WebHCatJTShim
null
.addCacheFile
in interface HadoopShims.WebHCatJTShim
public void killJobs(String tag, long timestamp)
killJobs
in interface HadoopShims.WebHCatJTShim
public Set<String> getJobs(String tag, long timestamp)
getJobs
in interface HadoopShims.WebHCatJTShim
Copyright © 2019 The Apache Software Foundation. All rights reserved.