org.apache.hadoop.hbase.coprocessor

Class TestRegionObserverInterface.EvenOnlyCompactor

java.lang.Object

org.apache.hadoop.hbase.coprocessor.BaseRegionObserver

org.apache.hadoop.hbase.coprocessor.TestRegionObserverInterface.EvenOnlyCompactor

All Implemented Interfaces:

Coprocessor, RegionObserver

Enclosing class:

TestRegionObserverInterface

public static class TestRegionObserverInterface.EvenOnlyCompactor
extends BaseRegionObserver

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
EvenOnlyCompactor()

Method Summary

Modifier and Type	Method and Description
void	postCompact(ObserverContext<RegionCoprocessorEnvironment> e, Store store, StoreFile resultFile) Called after compaction has completed and the new store file has been moved in to place.
void	postFlush(ObserverContext<RegionCoprocessorEnvironment> e) Called after the memstore is flushed to disk.
InternalScanner	preCompact(ObserverContext<RegionCoprocessorEnvironment> e, Store store, InternalScanner scanner, ScanType scanType) Called prior to writing the StoreFiles selected for compaction into a new StoreFile.

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

postAppend, postBatchMutate, postBatchMutateIndispensably, postBulkLoadHFile, postBulkLoadHFile, postCheckAndDelete, postCheckAndPut, postClose, postCloseRegionOperation, postCommitStoreFile, postCompact, postCompactSelection, postCompactSelection, postCompleteSplit, postDelete, postExists, 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, preCommitStoreFile, 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

EvenOnlyCompactor

public EvenOnlyCompactor()

Method Detail

preCompact

public InternalScanner preCompact(ObserverContext<RegionCoprocessorEnvironment> e,
                                  Store store,
                                  InternalScanner scanner,
                                  ScanType scanType)

Description copied from interface: RegionObserver

Called prior to writing the StoreFiles selected for compaction into a new StoreFile. To override or modify the compaction process, implementing classes have two options:

• Wrap the provided InternalScanner with a custom implementation that is returned from this method. The custom scanner can then inspect KeyValues from the wrapped scanner, applying its own policy to what gets written.
• Call ObserverContext.bypass() and provide a custom implementation for writing of new StoreFiles. Note: any implementations bypassing core compaction using this approach must write out new store files themselves or the existing data will no longer be available after compaction.

Specified by:

preCompact in interface RegionObserver

Overrides:

preCompact in class BaseRegionObserver

Parameters:

e - the environment provided by the region server

store - the store being compacted

scanner - the scanner over existing data used in the store file rewriting

scanType - type of Scan

Returns:

the scanner to use during compaction. Should not be null unless the implementation is writing new store files on its own.

postCompact

public void postCompact(ObserverContext<RegionCoprocessorEnvironment> e,
                        Store store,
                        StoreFile resultFile)

Description copied from interface: RegionObserver

Called after compaction has completed and the new store file has been moved in to place.

Specified by:

postCompact in interface RegionObserver

Overrides:

postCompact in class BaseRegionObserver

Parameters:

e - the environment provided by the region server

store - the store being compacted

resultFile - the new store file written out during compaction

postFlush

public void postFlush(ObserverContext<RegionCoprocessorEnvironment> e)

Description copied from interface: RegionObserver

Called after the memstore is flushed to disk.

Specified by:

postFlush in interface RegionObserver

Overrides:

postFlush in class BaseRegionObserver

Parameters:

e - the environment provided by the region server