class MapReduceBackupCopyJob.BackupDistCp extends org.apache.hadoop.tools.DistCp
Modifier and Type | Field and Description |
---|---|
private BackupInfo |
backupInfo |
private BackupManager |
backupManager |
Constructor and Description |
---|
BackupDistCp(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.tools.DistCpOptions options,
BackupInfo backupInfo,
BackupManager backupManager) |
Modifier and Type | Method and 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) |
createAndSubmitJob, getContext, getFileListingPath, main, run, waitForJobCompletion
private BackupInfo backupInfo
private BackupManager backupManager
public BackupDistCp(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.tools.DistCpOptions options, BackupInfo backupInfo, BackupManager backupManager) throws Exception
Exception
public org.apache.hadoop.mapreduce.Job execute() throws Exception
execute
in class org.apache.hadoop.tools.DistCp
Exception
private Field getInputOptionsField(Class<?> classDistCp) throws IOException
IOException
private List<org.apache.hadoop.fs.Path> getSourcePaths(Field fieldInputOptions) throws IOException
IOException
protected org.apache.hadoop.fs.Path createInputFileListing(org.apache.hadoop.mapreduce.Job job) throws IOException
createInputFileListing
in class org.apache.hadoop.tools.DistCp
IOException
private org.apache.hadoop.io.Text getKey(org.apache.hadoop.fs.Path path)
private List<org.apache.hadoop.fs.Path> getSourceFiles() throws NoSuchFieldException, SecurityException, IllegalArgumentException, IllegalAccessException, NoSuchMethodException, ClassNotFoundException, InvocationTargetException, IOException
private org.apache.hadoop.io.SequenceFile.Writer getWriter(org.apache.hadoop.fs.Path pathToListFile) throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.