org.apache.hadoop.hbase.master.snapshot

Class SnapshotManager

java.lang.Object

MasterProcedureManager

org.apache.hadoop.hbase.master.snapshot.SnapshotManager

public class SnapshotManager
extends MasterProcedureManager

This class manages the procedure of taking and restoring snapshots. There is only one SnapshotManager for the master.

The class provides methods for monitoring in-progress snapshot actions.

Note: Currently there can only be one snapshot being taken at a time over the cluster. This is a simplification in the current implementation.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	HBASE_SNAPSHOT_ENABLED Enable or disable snapshot support
static java.lang.String	ONLINE_SNAPSHOT_CONTROLLER_DESCRIPTION Name of the operation to use in the controller

Constructor Summary

Constructors

Constructor and Description
SnapshotManager()
SnapshotManager(MasterServices master, MetricsMaster metricsMaster, ProcedureCoordinator coordinator, ExecutorService pool) Fully specify all necessary components of a snapshot manager.

Method Summary

Modifier and Type	Method and Description
void	checkPermissions(ProcedureDescription desc, AccessChecker accessChecker, User user)
void	checkSnapshotSupport() Throws an exception if snapshot operations (take a snapshot, restore, clone) are not supported.
void	deleteSnapshot(SnapshotDescription snapshot) Delete the specified snapshot
void	execProcedure(ProcedureDescription desc)
java.util.List<SnapshotDescription>	getCompletedSnapshots() Gets the list of all completed snapshots.
<any>	getLocks()
java.lang.String	getProcedureSignature()
void	initialize(MasterServices master, MetricsMaster metricsMaster)
boolean	isProcedureDone(ProcedureDescription desc)
boolean	isSnapshotDone(SnapshotDescription expected) Check if the specified snapshot is done
boolean	isStopped()
long	restoreOrCloneSnapshot(SnapshotDescription reqSnapshot, NonceKey nonceKey, boolean restoreAcl) Restore or Clone the specified snapshot
void	setSnapshotHandlerForTesting(TableName tableName, SnapshotSentinel handler) Set the handler for the current snapshot
void	stop(java.lang.String why)
void	takeSnapshot(SnapshotDescription snapshot) Take a snapshot based on the enabled/disabled state of the table.

Methods inherited from class java.lang.Object

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

Field Detail

HBASE_SNAPSHOT_ENABLED

public static final java.lang.String HBASE_SNAPSHOT_ENABLED

Enable or disable snapshot support

See Also:

Constant Field Values

ONLINE_SNAPSHOT_CONTROLLER_DESCRIPTION

public static final java.lang.String ONLINE_SNAPSHOT_CONTROLLER_DESCRIPTION

Name of the operation to use in the controller

See Also:

Constant Field Values

Constructor Detail

SnapshotManager

public SnapshotManager()

SnapshotManager

public SnapshotManager(MasterServices master,
                       MetricsMaster metricsMaster,
                       ProcedureCoordinator coordinator,
                       ExecutorService pool)
                throws java.io.IOException,
                       java.lang.UnsupportedOperationException

Fully specify all necessary components of a snapshot manager. Exposed for testing.

Parameters:

master - services for the master where the manager is running

coordinator - procedure coordinator instance. exposed for testing.

pool - HBase ExecutorServcie instance, exposed for testing.

Throws:

java.io.IOException

java.lang.UnsupportedOperationException

Method Detail

getCompletedSnapshots

public java.util.List<SnapshotDescription> getCompletedSnapshots()
                                                          throws java.io.IOException

Gets the list of all completed snapshots.

Returns:

list of SnapshotDescriptions

Throws:

java.io.IOException - File system exception

deleteSnapshot

public void deleteSnapshot(SnapshotDescription snapshot)
                    throws SnapshotDoesNotExistException,
                           java.io.IOException

Delete the specified snapshot

Parameters:

snapshot -

Throws:

SnapshotDoesNotExistException - If the specified snapshot does not exist.

java.io.IOException - For filesystem IOExceptions

isSnapshotDone

public boolean isSnapshotDone(SnapshotDescription expected)
                       throws java.io.IOException

Check if the specified snapshot is done

Parameters:

expected -

Returns:

true if snapshot is ready to be restored, false if it is still being taken.

Throws:

java.io.IOException - IOException if error from HDFS or RPC

UnknownSnapshotException - if snapshot is invalid or does not exist.

takeSnapshot

public void takeSnapshot(SnapshotDescription snapshot)
                  throws java.io.IOException

Take a snapshot based on the enabled/disabled state of the table.

Parameters:

snapshot -

Throws:

HBaseSnapshotException - when a snapshot specific exception occurs.

java.io.IOException - when some sort of generic IO exception occurs.

setSnapshotHandlerForTesting

public void setSnapshotHandlerForTesting(TableName tableName,
                                         SnapshotSentinel handler)

Set the handler for the current snapshot

Exposed for TESTING

Parameters:

tableName -

handler - handler the master should use TODO get rid of this if possible, repackaging, modify tests.

restoreOrCloneSnapshot

public long restoreOrCloneSnapshot(SnapshotDescription reqSnapshot,
                                   NonceKey nonceKey,
                                   boolean restoreAcl)
                            throws java.io.IOException

Restore or Clone the specified snapshot

Parameters:

reqSnapshot -

nonceKey - unique identifier to prevent duplicated RPC

Throws:

java.io.IOException

stop

public void stop(java.lang.String why)

isStopped

public boolean isStopped()

checkSnapshotSupport

public void checkSnapshotSupport()
                          throws java.lang.UnsupportedOperationException

Throws an exception if snapshot operations (take a snapshot, restore, clone) are not supported. Called at the beginning of snapshot() and restoreSnapshot() methods.

Throws:

java.lang.UnsupportedOperationException - if snapshot are not supported

initialize

public void initialize(MasterServices master,
                       MetricsMaster metricsMaster)
                throws KeeperException,
                       java.io.IOException,
                       java.lang.UnsupportedOperationException

Throws:

KeeperException

java.io.IOException

java.lang.UnsupportedOperationException

getProcedureSignature

public java.lang.String getProcedureSignature()

execProcedure

public void execProcedure(ProcedureDescription desc)
                   throws java.io.IOException

Throws:

java.io.IOException

checkPermissions

public void checkPermissions(ProcedureDescription desc,
                             AccessChecker accessChecker,
                             User user)
                      throws java.io.IOException

Throws:

java.io.IOException

isProcedureDone

public boolean isProcedureDone(ProcedureDescription desc)
                        throws java.io.IOException

Throws:

java.io.IOException

getLocks

public <any> getLocks()