org.apache.hadoop.hive.shims

Interface HadoopShims.HCatHadoopShims

Enclosing interface:

HadoopShims

public static interface HadoopShims.HCatHadoopShims

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	HadoopShims.HCatHadoopShims.PropertyName

Method Summary

Modifier and Type	Method and Description
void	abortJob(org.apache.hadoop.mapreduce.OutputFormat outputFormat, org.apache.hadoop.mapreduce.Job job)
void	commitJob(org.apache.hadoop.mapreduce.OutputFormat outputFormat, org.apache.hadoop.mapreduce.Job job)
org.apache.hadoop.mapreduce.JobContext	createJobContext(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.mapreduce.JobID jobId)
org.apache.hadoop.mapred.JobContext	createJobContext(org.apache.hadoop.mapred.JobConf conf, org.apache.hadoop.mapreduce.JobID jobId, org.apache.hadoop.util.Progressable progressable)
org.apache.hadoop.mapreduce.TaskAttemptContext	createTaskAttemptContext(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.mapreduce.TaskAttemptID taskId)
org.apache.hadoop.mapred.TaskAttemptContext	createTaskAttemptContext(org.apache.hadoop.mapred.JobConf conf, org.apache.hadoop.mapred.TaskAttemptID taskId, org.apache.hadoop.util.Progressable progressable)
org.apache.hadoop.mapreduce.TaskAttemptID	createTaskAttemptID()
org.apache.hadoop.mapreduce.TaskID	createTaskID()
String	getPropertyName(HadoopShims.HCatHadoopShims.PropertyName name)
InetSocketAddress	getResourceManagerAddress(org.apache.hadoop.conf.Configuration conf)
boolean	isFileInHDFS(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path) Checks if file is in HDFS filesystem.

Method Detail

createTaskID

org.apache.hadoop.mapreduce.TaskID createTaskID()

createTaskAttemptID

org.apache.hadoop.mapreduce.TaskAttemptID createTaskAttemptID()

createTaskAttemptContext

org.apache.hadoop.mapreduce.TaskAttemptContext createTaskAttemptContext(org.apache.hadoop.conf.Configuration conf,
                                                                        org.apache.hadoop.mapreduce.TaskAttemptID taskId)

createTaskAttemptContext

org.apache.hadoop.mapred.TaskAttemptContext createTaskAttemptContext(org.apache.hadoop.mapred.JobConf conf,
                                                                     org.apache.hadoop.mapred.TaskAttemptID taskId,
                                                                     org.apache.hadoop.util.Progressable progressable)

createJobContext

org.apache.hadoop.mapreduce.JobContext createJobContext(org.apache.hadoop.conf.Configuration conf,
                                                        org.apache.hadoop.mapreduce.JobID jobId)

createJobContext

org.apache.hadoop.mapred.JobContext createJobContext(org.apache.hadoop.mapred.JobConf conf,
                                                     org.apache.hadoop.mapreduce.JobID jobId,
                                                     org.apache.hadoop.util.Progressable progressable)

commitJob

void commitJob(org.apache.hadoop.mapreduce.OutputFormat outputFormat,
               org.apache.hadoop.mapreduce.Job job)
        throws IOException

Throws:

IOException

abortJob

void abortJob(org.apache.hadoop.mapreduce.OutputFormat outputFormat,
              org.apache.hadoop.mapreduce.Job job)
       throws IOException

Throws:

IOException

getResourceManagerAddress

InetSocketAddress getResourceManagerAddress(org.apache.hadoop.conf.Configuration conf)

getPropertyName

String getPropertyName(HadoopShims.HCatHadoopShims.PropertyName name)

isFileInHDFS

boolean isFileInHDFS(org.apache.hadoop.fs.FileSystem fs,
                     org.apache.hadoop.fs.Path path)
              throws IOException

Checks if file is in HDFS filesystem.

Parameters:

fs -

path -

Returns:

true if the file is in HDFS, false if the file is in other file systems.

Throws:

IOException