@InterfaceAudience.LimitedPrivate(value="Configuration") public class BackupObserver extends BaseRegionObserver
RegionObserver.MutationType
Coprocessor.State
PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION
Constructor and Description |
---|
BackupObserver() |
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.
|
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
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
RegionObserver
postBulkLoadHFile
in interface RegionObserver
postBulkLoadHFile
in class BaseRegionObserver
stagingFamilyPaths
- pairs of { CF, HFile path } submitted for bulk loadfinalPaths
- Map of CF to List of file paths for the final loaded fileshasLoaded
- whether the bulkLoad was successfuljava.io.IOException
public void preCommitStoreFile(ObserverContext<RegionCoprocessorEnvironment> ctx, byte[] family, java.util.List<Pair<Path,Path>> pairs) throws java.io.IOException
RegionObserver
preCommitStoreFile
in interface RegionObserver
preCommitStoreFile
in class BaseRegionObserver
family
- column familypairs
- List of pairs of { HFile location in staging dir, HFile path in region dir }
Each pair are for the same hfile.java.io.IOException