public static interface HadoopShims.HCatHadoopShims
Modifier and Type | Interface and Description |
---|---|
static class |
HadoopShims.HCatHadoopShims.PropertyName |
Modifier and Type | Method and Description |
---|---|
void |
abortJob(OutputFormat outputFormat,
Job job) |
void |
commitJob(OutputFormat outputFormat,
Job job) |
JobContext |
createJobContext(Configuration conf,
JobID jobId) |
org.apache.hadoop.mapred.JobContext |
createJobContext(JobConf conf,
JobID jobId,
Progressable progressable) |
org.apache.hadoop.mapreduce.TaskAttemptContext |
createTaskAttemptContext(Configuration conf,
TaskAttemptID taskId) |
org.apache.hadoop.mapred.TaskAttemptContext |
createTaskAttemptContext(JobConf conf,
org.apache.hadoop.mapred.TaskAttemptID taskId,
Progressable progressable) |
TaskAttemptID |
createTaskAttemptID() |
TaskID |
createTaskID() |
java.lang.String |
getPropertyName(HadoopShims.HCatHadoopShims.PropertyName name) |
java.net.InetSocketAddress |
getResourceManagerAddress(Configuration conf) |
boolean |
isFileInHDFS(FileSystem fs,
Path path)
Checks if file is in HDFS filesystem.
|
TaskID createTaskID()
TaskAttemptID createTaskAttemptID()
org.apache.hadoop.mapreduce.TaskAttemptContext createTaskAttemptContext(Configuration conf, TaskAttemptID taskId)
org.apache.hadoop.mapred.TaskAttemptContext createTaskAttemptContext(JobConf conf, org.apache.hadoop.mapred.TaskAttemptID taskId, Progressable progressable)
JobContext createJobContext(Configuration conf, JobID jobId)
org.apache.hadoop.mapred.JobContext createJobContext(JobConf conf, JobID jobId, Progressable progressable)
void commitJob(OutputFormat outputFormat, Job job) throws java.io.IOException
java.io.IOException
void abortJob(OutputFormat outputFormat, Job job) throws java.io.IOException
java.io.IOException
java.net.InetSocketAddress getResourceManagerAddress(Configuration conf)
java.lang.String getPropertyName(HadoopShims.HCatHadoopShims.PropertyName name)
boolean isFileInHDFS(FileSystem fs, Path path) throws java.io.IOException
fs
- path
- java.io.IOException
Copyright © 2012 The Apache Software Foundation