Package org.apache.hadoop.hbase.backup.mapreduce

Class MapReduceRestoreToOriginalSplitsJob

java.lang.Object

org.apache.hadoop.hbase.backup.mapreduce.MapReduceRestoreToOriginalSplitsJob

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, RestoreJob

@Private
public class MapReduceRestoreToOriginalSplitsJob
extends Object
implements RestoreJob

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.conf.Configuration	conf

Fields inherited from interface org.apache.hadoop.hbase.backup.RestoreJob

BACKUP_ROOT_PATH_KEY, KEEP_ORIGINAL_SPLITS_DEFAULT, KEEP_ORIGINAL_SPLITS_KEY

Constructor Summary

Constructors

Constructor	Description
MapReduceRestoreToOriginalSplitsJob()

Method Summary

Modifier and Type	Method	Description
private static Map<byte[],List<org.apache.hadoop.fs.Path>>	buildFamily2Files(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path[] dirs, boolean isFullBackup)
private static Map<byte[],List<org.apache.hadoop.fs.Path>>	buildFullBackupFamily2Files(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path[] dirs)
org.apache.hadoop.conf.Configuration	getConf()
void	run(org.apache.hadoop.fs.Path[] dirPaths, TableName[] fromTables, org.apache.hadoop.fs.Path restoreRootDir, TableName[] toTables, boolean fullBackupRestore)	Run restore operation
void	setConf(org.apache.hadoop.conf.Configuration configuration)

Methods inherited from class java.lang.Object

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

Field Details

conf

private org.apache.hadoop.conf.Configuration conf

Constructor Details

MapReduceRestoreToOriginalSplitsJob

public MapReduceRestoreToOriginalSplitsJob()

Method Details

run

public void run(org.apache.hadoop.fs.Path[] dirPaths,
 TableName[] fromTables,
 org.apache.hadoop.fs.Path restoreRootDir,
 TableName[] toTables,
 boolean fullBackupRestore)
         throws IOException

Description copied from interface: RestoreJob

Run restore operation

Specified by:

run in interface RestoreJob

Parameters:

dirPaths - path array of WAL log directories

fromTables - from tables

restoreRootDir - output file system

toTables - to tables

fullBackupRestore - full backup restore

Throws:

IOException - if running the job fails

setConf

public void setConf(org.apache.hadoop.conf.Configuration configuration)

Specified by:

setConf in interface org.apache.hadoop.conf.Configurable

getConf

public org.apache.hadoop.conf.Configuration getConf()

Specified by:

getConf in interface org.apache.hadoop.conf.Configurable

buildFamily2Files

private static Map<byte[],List<org.apache.hadoop.fs.Path>> buildFamily2Files(org.apache.hadoop.fs.FileSystem fs,
 org.apache.hadoop.fs.Path[] dirs,
 boolean isFullBackup)
                                                                      throws IOException

Throws:

IOException

buildFullBackupFamily2Files

private static Map<byte[],List<org.apache.hadoop.fs.Path>> buildFullBackupFamily2Files(org.apache.hadoop.fs.FileSystem fs,
 org.apache.hadoop.fs.Path[] dirs)
                                                                                throws IOException

Throws:

IOException