@InterfaceAudience.Private public class MapReduceBackupCopyJob extends Object implements BackupCopyJob
BackupCopyJob
. Basically, there are 2 types of copy
operation: one is copying from snapshot, which bases on extending ExportSnapshot's function, the
other is copying for incremental log files, which bases on extending DistCp's function.Modifier and Type | Class and Description |
---|---|
(package private) class |
MapReduceBackupCopyJob.BackupDistCp
Extends DistCp for progress updating to backup system table during backup.
|
(package private) static class |
MapReduceBackupCopyJob.SnapshotCopy |
Modifier and Type | Field and Description |
---|---|
private long |
bytesCopied |
private org.apache.hadoop.conf.Configuration |
conf |
private static float |
INIT_PROGRESS |
private static org.slf4j.Logger |
LOG |
static String |
NUMBER_OF_LEVELS_TO_PRESERVE_KEY |
private float |
progressDone |
private float |
subTaskPercntgInWholeTask |
Constructor and Description |
---|
MapReduceBackupCopyJob() |
Modifier and Type | Method and Description |
---|---|
void |
cancel(String jobId)
Cancel copy job
|
int |
copy(BackupInfo context,
BackupManager backupManager,
org.apache.hadoop.conf.Configuration conf,
BackupType copyType,
String[] options)
Do backup copy based on different types.
|
org.apache.hadoop.conf.Configuration |
getConf() |
float |
getSubTaskPercntgInWholeTask()
Get the current copy task percentage within the whole task if multiple copies are needed.
|
void |
setConf(org.apache.hadoop.conf.Configuration conf) |
void |
setSubTaskPercntgInWholeTask(float subTaskPercntgInWholeTask)
Set the current copy task percentage within the whole task if multiple copies are needed.
|
(package private) static void |
updateProgress(BackupInfo backupInfo,
BackupManager backupManager,
int newProgress,
long bytesCopied)
Update the ongoing backup with new progress.
|
public static final String NUMBER_OF_LEVELS_TO_PRESERVE_KEY
private static final org.slf4j.Logger LOG
private org.apache.hadoop.conf.Configuration conf
private float progressDone
private long bytesCopied
private static float INIT_PROGRESS
private float subTaskPercntgInWholeTask
public MapReduceBackupCopyJob()
public org.apache.hadoop.conf.Configuration getConf()
getConf
in interface org.apache.hadoop.conf.Configurable
public void setConf(org.apache.hadoop.conf.Configuration conf)
setConf
in interface org.apache.hadoop.conf.Configurable
public float getSubTaskPercntgInWholeTask()
public void setSubTaskPercntgInWholeTask(float subTaskPercntgInWholeTask)
copy(BackupInfo, BackupManager, Configuration, BackupType, String[])
subTaskPercntgInWholeTask
- The percentage of the copy subtaskstatic void updateProgress(BackupInfo backupInfo, BackupManager backupManager, int newProgress, long bytesCopied) throws IOException
backupInfo
- backup infonewProgress
- progressbytesCopied
- bytes copiedIOException
- exceptionpublic int copy(BackupInfo context, BackupManager backupManager, org.apache.hadoop.conf.Configuration conf, BackupType copyType, String[] options) throws IOException
copy
in interface BackupCopyJob
context
- The backup infoconf
- The hadoop configurationcopyType
- The backup copy typeoptions
- Options for customized ExportSnapshot or DistCpbackupManager
- backup managerIOException
- exceptionpublic void cancel(String jobId) throws IOException
BackupCopyJob
cancel
in interface BackupCopyJob
jobId
- backup copy job handlerIOException
- if cancelling the jobs failsCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.