@InterfaceAudience.Private public abstract class TableBackupClient extends Object
FullTableBackupClient
and
IncrementalTableBackupClient
Modifier and Type | Class and Description |
---|---|
static class |
TableBackupClient.Stage |
Modifier and Type | Field and Description |
---|---|
static String |
BACKUP_CLIENT_IMPL_CLASS |
static String |
BACKUP_TEST_MODE_STAGE |
protected String |
backupId |
protected BackupInfo |
backupInfo |
protected BackupManager |
backupManager |
protected org.apache.hadoop.conf.Configuration |
conf |
protected Connection |
conn |
protected org.apache.hadoop.fs.FileSystem |
fs |
private static org.slf4j.Logger |
LOG |
protected Map<String,Long> |
newTimestamps |
protected List<TableName> |
tableList |
Constructor and Description |
---|
TableBackupClient() |
TableBackupClient(Connection conn,
String backupId,
BackupRequest request) |
Modifier and Type | Method and Description |
---|---|
protected void |
addManifest(BackupInfo backupInfo,
BackupManager backupManager,
BackupType type,
org.apache.hadoop.conf.Configuration conf)
Add manifest for the current backup.
|
protected void |
beginBackup(BackupManager backupManager,
BackupInfo backupInfo)
Begin the overall backup.
|
static void |
cleanupAndRestoreBackupSystem(Connection conn,
BackupInfo backupInfo,
org.apache.hadoop.conf.Configuration conf) |
protected static void |
cleanupExportSnapshotLog(org.apache.hadoop.conf.Configuration conf)
Clean up directories with prefix "exportSnapshot-", which are generated when exporting
snapshots.
|
protected static void |
cleanupTargetDir(BackupInfo backupInfo,
org.apache.hadoop.conf.Configuration conf)
Clean up the uncompleted data at target directory if the ongoing backup has already entered the
copy phase.
|
protected void |
completeBackup(Connection conn,
BackupInfo backupInfo,
BackupManager backupManager,
BackupType type,
org.apache.hadoop.conf.Configuration conf)
Complete the overall backup.
|
protected static void |
deleteSnapshots(Connection conn,
BackupInfo backupInfo,
org.apache.hadoop.conf.Configuration conf)
Delete HBase snapshot for backup.
|
abstract void |
execute()
Backup request execution.
|
protected void |
failBackup(Connection conn,
BackupInfo backupInfo,
BackupManager backupManager,
Exception e,
String msg,
BackupType type,
org.apache.hadoop.conf.Configuration conf)
Fail the overall backup.
|
protected void |
failStageIf(TableBackupClient.Stage stage) |
protected String |
getMessage(Exception e) |
protected TableBackupClient.Stage |
getTestStage() |
void |
init(Connection conn,
String backupId,
BackupRequest request) |
protected String |
obtainBackupMetaDataStr(BackupInfo backupInfo)
Get backup request meta data dir as string.
|
public static final String BACKUP_CLIENT_IMPL_CLASS
public static final String BACKUP_TEST_MODE_STAGE
private static final org.slf4j.Logger LOG
protected org.apache.hadoop.conf.Configuration conf
protected Connection conn
protected Map<String,Long> newTimestamps
protected BackupManager backupManager
protected BackupInfo backupInfo
protected org.apache.hadoop.fs.FileSystem fs
public TableBackupClient()
public TableBackupClient(Connection conn, String backupId, BackupRequest request) throws IOException
IOException
public void init(Connection conn, String backupId, BackupRequest request) throws IOException
IOException
protected void beginBackup(BackupManager backupManager, BackupInfo backupInfo) throws IOException
backupInfo
- backup infoIOException
- exceptionprotected String getMessage(Exception e)
protected static void deleteSnapshots(Connection conn, BackupInfo backupInfo, org.apache.hadoop.conf.Configuration conf) throws IOException
backupInfo
- backup infoIOException
- exceptionprotected static void cleanupExportSnapshotLog(org.apache.hadoop.conf.Configuration conf) throws IOException
IOException
- exceptionprotected static void cleanupTargetDir(BackupInfo backupInfo, org.apache.hadoop.conf.Configuration conf)
protected void failBackup(Connection conn, BackupInfo backupInfo, BackupManager backupManager, Exception e, String msg, BackupType type, org.apache.hadoop.conf.Configuration conf) throws IOException
backupInfo
- backup infoe
- exceptionIOException
- exceptionpublic static void cleanupAndRestoreBackupSystem(Connection conn, BackupInfo backupInfo, org.apache.hadoop.conf.Configuration conf) throws IOException
IOException
protected void addManifest(BackupInfo backupInfo, BackupManager backupManager, BackupType type, org.apache.hadoop.conf.Configuration conf) throws IOException
backupInfo
- The current backup infoIOException
- exceptionprotected String obtainBackupMetaDataStr(BackupInfo backupInfo)
backupInfo
- backup infoprotected void completeBackup(Connection conn, BackupInfo backupInfo, BackupManager backupManager, BackupType type, org.apache.hadoop.conf.Configuration conf) throws IOException
backupInfo
- backup infoIOException
- exceptionpublic abstract void execute() throws IOException
IOException
- if the execution of the backup failsprotected TableBackupClient.Stage getTestStage()
protected void failStageIf(TableBackupClient.Stage stage) throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.