@InterfaceAudience.Private public class MapReduceRestoreJob extends Object implements RestoreJob
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
.Modifier and Type | Field and Description |
---|---|
private org.apache.hadoop.conf.Configuration |
conf |
static org.slf4j.Logger |
LOG |
private org.apache.hadoop.util.Tool |
player |
Constructor and Description |
---|
MapReduceRestoreJob() |
Modifier and Type | Method and 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) |
public static final org.slf4j.Logger LOG
private org.apache.hadoop.util.Tool player
private org.apache.hadoop.conf.Configuration conf
public MapReduceRestoreJob()
public void run(org.apache.hadoop.fs.Path[] dirPaths, TableName[] tableNames, org.apache.hadoop.fs.Path restoreRootDir, TableName[] newTableNames, boolean fullBackupRestore) throws IOException
RestoreJob
run
in interface RestoreJob
dirPaths
- path array of WAL log directoriestableNames
- from tablesrestoreRootDir
- output file systemnewTableNames
- to tablesfullBackupRestore
- full backup restoreIOException
- if running the job failspublic org.apache.hadoop.conf.Configuration getConf()
getConf
in interface org.apache.hadoop.conf.Configurable
public void setConf(org.apache.hadoop.conf.Configuration conf)
setConf
in interface org.apache.hadoop.conf.Configurable
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.