org.apache.hadoop.hbase.mapreduce

Class JobUtil

java.lang.Object

org.apache.hadoop.hbase.mapreduce.JobUtil

@InterfaceAudience.Private
 @InterfaceStability.Evolving
public abstract class JobUtil
extends Object

Utility methods to interact with a job.

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	JobUtil()

Method Summary

Modifier and Type	Method and Description
static org.apache.hadoop.fs.Path	getQualifiedStagingDir(org.apache.hadoop.conf.Configuration conf) Initializes the staging directory and returns the qualified path.
static org.apache.hadoop.fs.Path	getStagingDir(org.apache.hadoop.conf.Configuration conf) Initializes the staging directory and returns the path.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOG

private static final org.slf4j.Logger LOG

Constructor Detail

JobUtil

protected JobUtil()

Method Detail

getStagingDir

public static org.apache.hadoop.fs.Path getStagingDir(org.apache.hadoop.conf.Configuration conf)
                                               throws IOException,
                                                      InterruptedException

Initializes the staging directory and returns the path.

Parameters:

conf - system configuration

Returns:

staging directory path

Throws:

IOException - if the ownership on the staging directory is not as expected

InterruptedException - if the thread getting the staging directory is interrupted

getQualifiedStagingDir

public static org.apache.hadoop.fs.Path getQualifiedStagingDir(org.apache.hadoop.conf.Configuration conf)
                                                        throws IOException,
                                                               InterruptedException

Initializes the staging directory and returns the qualified path.

Parameters:

conf - conf system configuration

Returns:

qualified staging directory path

Throws:

IOException - if the ownership on the staging directory is not as expected

InterruptedException - if the thread getting the staging directory is interrupted