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

Class RestoreTablesClient

java.lang.Object

org.apache.hadoop.hbase.backup.impl.RestoreTablesClient

@Private
public class RestoreTablesClient
extends Object

Restore table implementation

Field Summary

Fields

Modifier and Type	Field	Description
private String	backupId
private String	backupRootDir
private org.apache.hadoop.conf.Configuration	conf
private Connection	conn
private boolean	isOverwrite
private static final org.slf4j.Logger	LOG
private org.apache.hadoop.fs.Path	restoreRootDir
private TableName[]	sTableArray
private TableName[]	tTableArray

Constructor Summary

Constructors

Constructor	Description
RestoreTablesClient(Connection conn, RestoreRequest request)

Method Summary

Modifier and Type	Method	Description
private void	checkTargetTables(TableName[] tTableArray, boolean isOverwrite)	Validate target tables.
void	execute()
private List<org.apache.hadoop.fs.Path>	getFilesRecursively(String fileBackupDir)
(package private) static long	getTsFromBackupId(String backupId)
private void	restore(BackupManifest manifest, TableName[] sTableArray, TableName[] tTableArray, boolean isOverwrite)	Restore operation.
private void	restoreImages(BackupManifest.BackupImage[] images, TableName sTable, TableName tTable, boolean truncateIfExists)	Restore operation handle each backupImage in array.
(package private) static boolean	withinRange(long a, long lower, long upper)

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

conf

private org.apache.hadoop.conf.Configuration conf

conn

private Connection conn

backupId

private String backupId

sTableArray

private TableName[] sTableArray

tTableArray

private TableName[] tTableArray

backupRootDir

private String backupRootDir

restoreRootDir

private org.apache.hadoop.fs.Path restoreRootDir

isOverwrite

private boolean isOverwrite

Constructor Details

RestoreTablesClient

public RestoreTablesClient(Connection conn,
 RestoreRequest request)
                    throws IOException

Throws:

IOException

Method Details

checkTargetTables

private void checkTargetTables(TableName[] tTableArray,
 boolean isOverwrite)
                        throws IOException

Validate target tables.

Parameters:

tTableArray - target tables

isOverwrite - overwrite existing table

Throws:

IOException - exception

restoreImages

private void restoreImages(BackupManifest.BackupImage[] images,
 TableName sTable,
 TableName tTable,
 boolean truncateIfExists)
                    throws IOException

Restore operation handle each backupImage in array.

Parameters:

images - array BackupImage

sTable - table to be restored

tTable - table to be restored to

truncateIfExists - truncate table

Throws:

IOException - exception

getFilesRecursively

private List<org.apache.hadoop.fs.Path> getFilesRecursively(String fileBackupDir)
                                                     throws IllegalArgumentException,
IOException

Throws:

IllegalArgumentException

IOException

restore

private void restore(BackupManifest manifest,
 TableName[] sTableArray,
 TableName[] tTableArray,
 boolean isOverwrite)
              throws IOException

Restore operation. Stage 2: resolved Backup Image dependency

Parameters:

sTableArray - The array of tables to be restored

tTableArray - The array of mapping tables to restore to

Throws:

IOException - exception

getTsFromBackupId

static long getTsFromBackupId(String backupId)

withinRange

static boolean withinRange(long a,
 long lower,
 long upper)

execute

public void execute()
             throws IOException

Throws:

IOException