org.apache.hadoop.hbase.backup.mapreduce

Class MapReduceRestoreService

java.lang.Object

org.apache.hadoop.hbase.backup.mapreduce.MapReduceRestoreService

All Implemented Interfaces:

IncrementalRestoreService

@InterfaceAudience.Private
 @InterfaceStability.Evolving
public class MapReduceRestoreService
extends java.lang.Object
implements IncrementalRestoreService

Field Summary

Fields

Modifier and Type	Field and Description
static Log	LOG

Constructor Summary

Constructors

Constructor and Description
MapReduceRestoreService()

Method Summary

Modifier and Type	Method and Description
static LoadIncrementalHFiles	createLoader(Configuration conf)
Configuration	getConf()
void	run(Path[] fileDirPaths, TableName[] tableNames, TableName[] newTableNames) Run restore operation
void	setConf(Configuration conf)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final Log LOG

Constructor Detail

MapReduceRestoreService

public MapReduceRestoreService()

Method Detail

run

public void run(Path[] fileDirPaths,
                TableName[] tableNames,
                TableName[] newTableNames)
         throws java.io.IOException

Description copied from interface: IncrementalRestoreService

Run restore operation

Specified by:

run in interface IncrementalRestoreService

Parameters:

fileDirPaths - - path array of WAL log directories

tableNames - - from tables

newTableNames - - to tables

Throws:

java.io.IOException

createLoader

public static LoadIncrementalHFiles createLoader(Configuration conf)
                                          throws java.io.IOException

Throws:

java.io.IOException

getConf

public Configuration getConf()

setConf

public void setConf(Configuration conf)