org.apache.hcatalog.shims
Interface HCatHadoopShims

public interface HCatHadoopShims

Shim layer to abstract differences between Hadoop 0.20 and 0.23 (HCATALOG-179). This mirrors Hive shims, but is kept separate for HCatalog dependencies.

Nested Class Summary

static class	HCatHadoopShims.Instance
static class	HCatHadoopShims.PropertyName

Method Summary

void	abortJob(OutputFormat outputFormat, Job job)
void	commitJob(OutputFormat outputFormat, Job job)
JobContext	createJobContext(Configuration conf, JobID jobId)
JobContext	createJobContext(JobConf conf, JobID jobId, Progressable progressable)
TaskAttemptContext	createTaskAttemptContext(Configuration conf, TaskAttemptID taskId)
TaskAttemptContext	createTaskAttemptContext(JobConf conf, TaskAttemptID taskId, Progressable progressable)
TaskAttemptID	createTaskAttemptID()
TaskID	createTaskID()
String	getPropertyName(HCatHadoopShims.PropertyName name)
InetSocketAddress	getResourceManagerAddress(Configuration conf)
boolean	isFileInHDFS(FileSystem fs, Path path) Checks if file is in HDFS filesystem.

Method Detail

createTaskID

TaskID createTaskID()

createTaskAttemptID

TaskAttemptID createTaskAttemptID()

createTaskAttemptContext

TaskAttemptContext createTaskAttemptContext(Configuration conf,
                                            TaskAttemptID taskId)

createTaskAttemptContext

TaskAttemptContext createTaskAttemptContext(JobConf conf,
                                            TaskAttemptID taskId,
                                            Progressable progressable)

createJobContext

JobContext createJobContext(Configuration conf,
                            JobID jobId)

createJobContext

JobContext createJobContext(JobConf conf,
                            JobID jobId,
                            Progressable progressable)

commitJob

void commitJob(OutputFormat outputFormat,
               Job job)
               throws IOException

Throws:

IOException

abortJob

void abortJob(OutputFormat outputFormat,
              Job job)
              throws IOException

Throws:

IOException

getResourceManagerAddress

InetSocketAddress getResourceManagerAddress(Configuration conf)

getPropertyName

String getPropertyName(HCatHadoopShims.PropertyName name)

isFileInHDFS

boolean isFileInHDFS(FileSystem 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