Package org.apache.hadoop.hbase.backup.impl

Class IncrementalTableBackupClient

java.lang.Object

org.apache.hadoop.hbase.backup.impl.TableBackupClient

org.apache.hadoop.hbase.backup.impl.IncrementalTableBackupClient

@Private
public class IncrementalTableBackupClient
extends TableBackupClient

Incremental backup implementation. See the execute method.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.backup.impl.TableBackupClient

TableBackupClient.Stage

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG

Fields inherited from class org.apache.hadoop.hbase.backup.impl.TableBackupClient

BACKUP_CLIENT_IMPL_CLASS, BACKUP_TEST_MODE_STAGE, backupId, backupInfo, backupManager, conf, conn, fs, newTimestamps, tableList

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	IncrementalTableBackupClient()
	IncrementalTableBackupClient(Connection conn, String backupId, BackupRequest request)

Method Summary

Modifier and Type	Method	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)

Methods inherited from class org.apache.hadoop.hbase.backup.impl.TableBackupClient

addManifest, beginBackup, cleanupAndRestoreBackupSystem, cleanupExportSnapshotLog, cleanupTargetDir, completeBackup, deleteSnapshots, failBackup, failStageIf, getMessage, getTestStage, init, obtainBackupMetaDataStr

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOG

private static final org.slf4j.Logger LOG

Constructor Details

IncrementalTableBackupClient

protected IncrementalTableBackupClient()

IncrementalTableBackupClient

public IncrementalTableBackupClient(Connection conn,
 String backupId,
 BackupRequest request)
                             throws IOException

Throws:

IOException

Method Details

filterMissingFiles

protected List<String> filterMissingFiles(List<String> incrBackupFileList)
                                   throws IOException

Throws:

IOException

isActiveWalPath

protected boolean isActiveWalPath(org.apache.hadoop.fs.Path p)

Check if a given path is belongs to active WAL directory

Parameters:

p - path

Returns:

true, if yes

getIndex

protected static int getIndex(TableName tbl,
 List<TableName> sTableList)

handleBulkLoad

protected Map<byte[],List<org.apache.hadoop.fs.Path>>[] handleBulkLoad(List<TableName> sTableList)
                                                                throws IOException

Throws:

IOException

copyBulkLoadedFiles

private void copyBulkLoadedFiles(List<String> activeFiles,
 List<String> archiveFiles)
                          throws IOException

Throws:

IOException

updateFileLists

private void updateFileLists(List<String> activeFiles,
 List<String> archiveFiles)
                      throws IOException

Throws:

IOException

execute

public void execute()
             throws IOException

Description copied from class: TableBackupClient

Backup request execution.

Specified by:

execute in class TableBackupClient

Throws:

IOException - if the execution of the backup fails

incrementalCopyHFiles

protected void incrementalCopyHFiles(String[] files,
 String backupDest)
                              throws IOException

Throws:

IOException

deleteBulkLoadDirectory

protected void deleteBulkLoadDirectory()
                                throws IOException

Throws:

IOException

convertWALsToHFiles

protected void convertWALsToHFiles()
                            throws IOException

Throws:

IOException

tableExists

protected boolean tableExists(TableName table,
 Connection conn)
                       throws IOException

Throws:

IOException

walToHFiles

protected void walToHFiles(List<String> dirPaths,
 List<String> tableList)
                    throws IOException

Throws:

IOException

getBulkOutputDirForTable

protected org.apache.hadoop.fs.Path getBulkOutputDirForTable(TableName table)

getBulkOutputDir

protected org.apache.hadoop.fs.Path getBulkOutputDir()