org.apache.hadoop.hbase.backup

Class BackupObserver

java.lang.Object

org.apache.hadoop.hbase.coprocessor.BaseRegionObserver

org.apache.hadoop.hbase.backup.BackupObserver

All Implemented Interfaces:

Coprocessor, RegionObserver

@InterfaceAudience.LimitedPrivate(value="Configuration")
public class BackupObserver
extends BaseRegionObserver

An Observer to facilitate backup operations

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.coprocessor.RegionObserver

RegionObserver.MutationType

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

Coprocessor.State

Field Summary

Fields inherited from interface org.apache.hadoop.hbase.Coprocessor

PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION

Constructor Summary

Constructors

Constructor and Description
BackupObserver()

Method Summary

Modifier and Type	Method and Description
boolean	postBulkLoadHFile(ObserverContext<RegionCoprocessorEnvironment> ctx, java.util.List<Pair<byte[],java.lang.String>> stagingFamilyPaths, java.util.Map<byte[],java.util.List<Path>> finalPaths, boolean hasLoaded) Called after bulkLoadHFile.
void	preCommitStoreFile(ObserverContext<RegionCoprocessorEnvironment> ctx, byte[] family, java.util.List<Pair<Path,Path>> pairs) Called before moving bulk loaded hfile to region directory.

Methods inherited from class org.apache.hadoop.hbase.coprocessor.BaseRegionObserver

postAppend, postBatchMutate, postBatchMutateIndispensably, postBulkLoadHFile, postCheckAndDelete, postCheckAndPut, postClose, postCloseRegionOperation, postCommitStoreFile, postCompact, postCompact, postCompactSelection, postCompactSelection, postCompleteSplit, postDelete, postExists, postFlush, postFlush, postGetClosestRowBefore, postGetOp, postIncrement, postIncrementColumnValue, postInstantiateDeleteTracker, postLogReplay, postMutationBeforeWAL, postOpen, postPut, postRollBackSplit, postScannerClose, postScannerFilterRow, postScannerNext, postScannerOpen, postSplit, postStartRegionOperation, postStoreFileReaderOpen, postWALRestore, postWALRestore, preAppend, preAppendAfterRowLock, preBatchMutate, preBulkLoadHFile, preCheckAndDelete, preCheckAndDeleteAfterRowLock, preCheckAndPut, preCheckAndPutAfterRowLock, preClose, preCompact, preCompact, preCompactScannerOpen, preCompactScannerOpen, preCompactSelection, preCompactSelection, preDelete, preExists, preFlush, preFlush, preFlushScannerOpen, preGetClosestRowBefore, preGetOp, preIncrement, preIncrementAfterRowLock, preIncrementColumnValue, preOpen, prePrepareTimeStampForDeleteVersion, prePut, preRollBackSplit, preScannerClose, preScannerNext, preScannerOpen, preSplit, preSplit, preSplitAfterPONR, preSplitBeforePONR, preStoreFileReaderOpen, preStoreScannerOpen, preWALRestore, preWALRestore, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

BackupObserver

public BackupObserver()

Method Detail

postBulkLoadHFile

public boolean postBulkLoadHFile(ObserverContext<RegionCoprocessorEnvironment> ctx,
                                 java.util.List<Pair<byte[],java.lang.String>> stagingFamilyPaths,
                                 java.util.Map<byte[],java.util.List<Path>> finalPaths,
                                 boolean hasLoaded)
                          throws java.io.IOException

Description copied from interface: RegionObserver

Called after bulkLoadHFile.

Specified by:

postBulkLoadHFile in interface RegionObserver

Overrides:

postBulkLoadHFile in class BaseRegionObserver

stagingFamilyPaths - pairs of { CF, HFile path } submitted for bulk load

finalPaths - Map of CF to List of file paths for the final loaded files

hasLoaded - whether the bulkLoad was successful

Returns:

the new value of hasLoaded

Throws:

java.io.IOException

preCommitStoreFile

public void preCommitStoreFile(ObserverContext<RegionCoprocessorEnvironment> ctx,
                               byte[] family,
                               java.util.List<Pair<Path,Path>> pairs)
                        throws java.io.IOException

Description copied from interface: RegionObserver

Called before moving bulk loaded hfile to region directory.

Specified by:

preCommitStoreFile in interface RegionObserver

Overrides:

preCommitStoreFile in class BaseRegionObserver

family - column family

pairs - List of pairs of { HFile location in staging dir, HFile path in region dir } Each pair are for the same hfile.

Throws:

java.io.IOException