org.apache.hadoop.hbase.backup.mapreduce

Class MapReduceBackupCopyService

java.lang.Object

org.apache.hadoop.hbase.backup.mapreduce.MapReduceBackupCopyService

All Implemented Interfaces:

BackupCopyService

@InterfaceAudience.Private
 @InterfaceStability.Evolving
public class MapReduceBackupCopyService
extends Object
implements BackupCopyService

Copier for backup operation. Basically, there are 2 types of copy. One is copying from snapshot, which bases on extending ExportSnapshot's function with copy progress reporting to ZooKeeper implementation. The other is copying for incremental log files, which bases on extending DistCp's function with copy progress reporting to ZooKeeper implementation. For now this is only a wrapper. The other features such as progress and increment backup will be implemented in future jira

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.backup.BackupCopyService

BackupCopyService.Type

Constructor Summary

Constructors

Constructor and Description
MapReduceBackupCopyService()

Method Summary

Modifier and Type	Method and Description
void	cancelCopyJob(String jobId) Cancel copy job
int	copy(BackupInfo context, BackupManager backupManager, Configuration conf, BackupCopyService.Type copyType, String[] options) Do backup copy based on different types.
Configuration	getConf()
float	getSubTaskPercntgInWholeTask() Get the current copy task percentage within the whole task if multiple copies are needed.
void	setConf(Configuration conf)
void	setSubTaskPercntgInWholeTask(float subTaskPercntgInWholeTask) Set the current copy task percentage within the whole task if multiple copies are needed.

Methods inherited from class java.lang.Object

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

Constructor Detail

MapReduceBackupCopyService

public MapReduceBackupCopyService()

Method Detail

getConf

public Configuration getConf()

setConf

public void setConf(Configuration conf)

getSubTaskPercntgInWholeTask

public float getSubTaskPercntgInWholeTask()

Get the current copy task percentage within the whole task if multiple copies are needed.

Returns:

the current copy task percentage

setSubTaskPercntgInWholeTask

public void setSubTaskPercntgInWholeTask(float subTaskPercntgInWholeTask)

Set the current copy task percentage within the whole task if multiple copies are needed. Must be called before calling #copy(BackupHandler, Configuration, Type, String[])

Parameters:

subTaskPercntgInWholeTask - The percentage of the copy subtask

copy

public int copy(BackupInfo context,
                BackupManager backupManager,
                Configuration conf,
                BackupCopyService.Type copyType,
                String[] options)
         throws IOException

Do backup copy based on different types.

Specified by:

copy in interface BackupCopyService

Parameters:

context - The backup context

conf - The hadoop configuration

copyType - The backup copy type

options - Options for customized ExportSnapshot or DistCp

backupManager - - manager

Returns:

result (0 - success)

Throws:

Exception - exception

IOException

cancelCopyJob

public void cancelCopyJob(String jobId)
                   throws IOException

Description copied from interface: BackupCopyService

Cancel copy job

Specified by:

cancelCopyJob in interface BackupCopyService

Parameters:

jobId - - copy job handler

Throws:

IOException