Package org.apache.hadoop.hbase.mapreduce

Class JobUtil

java.lang.Object
org.apache.hadoop.hbase.mapreduce.JobUtil
@Private @Evolving public abstract class JobUtil extends Object
Utility methods to interact with a job.

  • Constructor Summary

    Constructors
    Modifier
    Constructor
    Description
    protected
    JobUtil()
     

  • Method Summary

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

  • Constructor Details

  • Method Details

    • 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