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.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	JobUtil()

Method Summary

Methods

Modifier and Type	Method and Description
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

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.

CLOUDERA-SPECIFIC-NOTE: MR1 and MR2 are incompatible regarding getStagingDir() API.

The following code is to handle both MR1 and MR2 at compile/run time. This is done using reflection to figure out the right API.

Parameters:

conf - system configuration

Returns:

staging directory path

Throws:

IOException

InterruptedException