@InterfaceAudience.Private public class IncrementalTableBackupClient extends TableBackupClient
execute
method.TableBackupClient.Stage
Modifier and Type | Field and Description |
---|---|
private static org.slf4j.Logger |
LOG |
BACKUP_CLIENT_IMPL_CLASS, BACKUP_TEST_MODE_STAGE, backupId, backupInfo, backupManager, conf, conn, fs, newTimestamps, tableList
Modifier | Constructor and Description |
---|---|
protected |
IncrementalTableBackupClient() |
|
IncrementalTableBackupClient(Connection conn,
String backupId,
BackupRequest request) |
Modifier and Type | Method and Description |
---|---|
protected void |
convertWALsToHFiles() |
private void |
copyBulkLoadedFiles(List<String> activeFiles,
List<String> archiveFiles) |
protected void |
deleteBulkLoadDirectory() |
void |
execute()
Backup request execution.
|
protected List<String> |
filterMissingFiles(List<String> incrBackupFileList) |
protected org.apache.hadoop.fs.Path |
getBulkOutputDir() |
protected org.apache.hadoop.fs.Path |
getBulkOutputDirForTable(TableName table) |
protected static int |
getIndex(TableName tbl,
List<TableName> sTableList) |
protected Map<byte[],List<org.apache.hadoop.fs.Path>>[] |
handleBulkLoad(List<TableName> sTableList) |
protected void |
incrementalCopyHFiles(String[] files,
String backupDest) |
protected boolean |
isActiveWalPath(org.apache.hadoop.fs.Path p)
Check if a given path is belongs to active WAL directory
|
protected boolean |
tableExists(TableName table,
Connection conn) |
private void |
updateFileLists(List<String> activeFiles,
List<String> archiveFiles) |
protected void |
walToHFiles(List<String> dirPaths,
List<String> tableList) |
addManifest, beginBackup, cleanupAndRestoreBackupSystem, cleanupExportSnapshotLog, cleanupTargetDir, completeBackup, deleteSnapshots, failBackup, failStageIf, getMessage, getTestStage, init, obtainBackupMetaDataStr
private static final org.slf4j.Logger LOG
protected IncrementalTableBackupClient()
public IncrementalTableBackupClient(Connection conn, String backupId, BackupRequest request) throws IOException
IOException
protected List<String> filterMissingFiles(List<String> incrBackupFileList) throws IOException
IOException
protected boolean isActiveWalPath(org.apache.hadoop.fs.Path p)
p
- pathprotected Map<byte[],List<org.apache.hadoop.fs.Path>>[] handleBulkLoad(List<TableName> sTableList) throws IOException
IOException
private void copyBulkLoadedFiles(List<String> activeFiles, List<String> archiveFiles) throws IOException
IOException
private void updateFileLists(List<String> activeFiles, List<String> archiveFiles) throws IOException
IOException
public void execute() throws IOException
TableBackupClient
execute
in class TableBackupClient
IOException
- if the execution of the backup failsprotected void incrementalCopyHFiles(String[] files, String backupDest) throws IOException
IOException
protected void deleteBulkLoadDirectory() throws IOException
IOException
protected void convertWALsToHFiles() throws IOException
IOException
protected boolean tableExists(TableName table, Connection conn) throws IOException
IOException
protected void walToHFiles(List<String> dirPaths, List<String> tableList) throws IOException
IOException
protected org.apache.hadoop.fs.Path getBulkOutputDirForTable(TableName table)
protected org.apache.hadoop.fs.Path getBulkOutputDir()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.