@InterfaceAudience.Private @InterfaceStability.Evolving public class MapReduceRestoreService extends java.lang.Object implements IncrementalRestoreService
Modifier and Type | Field and Description |
---|---|
static Log |
LOG |
Constructor and Description |
---|
MapReduceRestoreService() |
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) |
public void run(Path[] fileDirPaths, TableName[] tableNames, TableName[] newTableNames) throws java.io.IOException
IncrementalRestoreService
run
in interface IncrementalRestoreService
fileDirPaths
- - path array of WAL log directoriestableNames
- - from tablesnewTableNames
- - to tablesjava.io.IOException
public static LoadIncrementalHFiles createLoader(Configuration conf) throws java.io.IOException
java.io.IOException
public Configuration getConf()
public void setConf(Configuration conf)