Package org.apache.hadoop.hbase.backup.mapreduce

Class MapReduceBackupCopyJob.BackupDistCp

java.lang.Object
org.apache.hadoop.conf.Configured
org.apache.hadoop.tools.DistCp
org.apache.hadoop.hbase.backup.mapreduce.MapReduceBackupCopyJob.BackupDistCp
All Implemented Interfaces:
org.apache.hadoop.conf.Configurable, org.apache.hadoop.util.Tool
Enclosing class:
MapReduceBackupCopyJob
class MapReduceBackupCopyJob.BackupDistCp extends org.apache.hadoop.tools.DistCp
Extends DistCp for progress updating to backup system table during backup. Using DistCpV2 (MAPREDUCE-2765). Simply extend it and override execute() method to get the Job reference for progress updating. Only the argument "src1, [src2, [...]] dst" is supported, no more DistCp options.

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private BackupInfo
    backupInfo
     
    private BackupManager
    backupManager
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    BackupDistCp(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.tools.DistCpOptions options, BackupInfo backupInfo, BackupManager backupManager)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected org.apache.hadoop.fs.Path
    createInputFileListing(org.apache.hadoop.mapreduce.Job job)
     
    org.apache.hadoop.mapreduce.Job
    execute()
     
    private Field
    getInputOptionsField(Class<?> classDistCp)
     
    private org.apache.hadoop.io.Text
    getKey(org.apache.hadoop.fs.Path path)
     
    private List<org.apache.hadoop.fs.Path>
    getSourceFiles()
     
    private List<org.apache.hadoop.fs.Path>
    getSourcePaths(Field fieldInputOptions)
     
    private org.apache.hadoop.io.SequenceFile.Writer
    getWriter(org.apache.hadoop.fs.Path pathToListFile)
     

    Methods inherited from class org.apache.hadoop.tools.DistCp

    cleanup, createAndSubmitJob, getContext, getFileListingPath, main, run, waitForJobCompletion

    Methods inherited from class org.apache.hadoop.conf.Configured

    getConf, setConf

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.apache.hadoop.conf.Configurable

    getConf, setConf