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

Class MapReduceRestoreJob

java.lang.Object

org.apache.hadoop.hbase.backup.mapreduce.MapReduceRestoreJob

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, RestoreJob

@Private
public class MapReduceRestoreJob
extends Object
implements RestoreJob

MapReduce implementation of RestoreJob For backup restore, it runs MapReduceHFileSplitterJob job and creates HFiles which are aligned with a region boundaries of a table being restored. The resulting HFiles then are loaded using HBase bulk load tool BulkLoadHFiles.

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.conf.Configuration	conf
static final org.slf4j.Logger	LOG
private org.apache.hadoop.util.Tool	player

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
MapReduceRestoreJob()

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.conf.Configuration	getConf()
void	run(org.apache.hadoop.fs.Path[] dirPaths, TableName[] tableNames, org.apache.hadoop.fs.Path restoreRootDir, TableName[] newTableNames, boolean fullBackupRestore)	Run restore operation
void	setConf(org.apache.hadoop.conf.Configuration conf)

Methods inherited from class java.lang.Object

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

Field Details

LOG

public static final org.slf4j.Logger LOG

player

private org.apache.hadoop.util.Tool player

conf

private org.apache.hadoop.conf.Configuration conf

Constructor Details

MapReduceRestoreJob

public MapReduceRestoreJob()

Method Details

run

public void run(org.apache.hadoop.fs.Path[] dirPaths,
 TableName[] tableNames,
 org.apache.hadoop.fs.Path restoreRootDir,
 TableName[] newTableNames,
 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

tableNames - from tables

restoreRootDir - output file system

newTableNames - to tables

fullBackupRestore - full backup restore

Throws:

IOException - if running the job fails

getConf

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

Specified by:

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

setConf

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

Specified by:

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