@InterfaceAudience.Private public class IncrementalBackupManager extends BackupManager
Modifier and Type | Class and Description |
---|---|
(package private) static class |
IncrementalBackupManager.NewestLogFilter |
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
LOG |
BACKUP_EXCLUSIVE_OPERATION_TIMEOUT_SECONDS_KEY, backupInfo, conf, conn, systemTable
Constructor and Description |
---|
IncrementalBackupManager(Connection conn,
org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
private List<String> |
excludeProcV2WALs(List<String> logList) |
Map<String,Long> |
getIncrBackupLogFileMap()
Obtain the list of logs that need to be copied out for this incremental backup.
|
private List<String> |
getLogFilesForNewBackup(Map<String,Long> olderTimestamps,
Map<String,Long> newestTimestamps,
org.apache.hadoop.conf.Configuration conf,
String savedStartCode)
For each region server: get all log files newer than the last timestamps but not newer than the
newest timestamps.
|
addIncrementalBackupTableSet, close, createBackupInfo, decorateMasterConfiguration, decorateRegionServerConfiguration, deleteBulkLoadedRows, finishBackupSession, getAncestors, getAncestors, getBackupHistory, getBackupHistory, getBackupInfo, getConf, getConnection, getIncrementalBackupTableSet, initialize, isBackupEnabled, readBackupStartCode, readBulkloadRows, readLogTimestampMap, readRegionServerLastLogRollResult, setBackupInfo, startBackupSession, updateBackupInfo, writeBackupStartCode, writeRegionServerLogTimestamp
public static final org.slf4j.Logger LOG
public IncrementalBackupManager(Connection conn, org.apache.hadoop.conf.Configuration conf) throws IOException
IOException
public Map<String,Long> getIncrBackupLogFileMap() throws IOException
IOException
- exceptionprivate List<String> excludeProcV2WALs(List<String> logList)
private List<String> getLogFilesForNewBackup(Map<String,Long> olderTimestamps, Map<String,Long> newestTimestamps, org.apache.hadoop.conf.Configuration conf, String savedStartCode) throws IOException
olderTimestamps
- the timestamp for each region server of the last backup.newestTimestamps
- the timestamp for each region server that the backup should lead to.conf
- the Hadoop and Hbase configurationsavedStartCode
- the startcode (timestamp) of last successful backup.IOException
- exceptionCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.