co.cask.cdap.data2.transaction.queue.coprocessor.hbase98

Class HBaseQueueRegionObserver

java.lang.Object

org.apache.hadoop.hbase.coprocessor.BaseRegionObserver

co.cask.cdap.data2.transaction.queue.coprocessor.hbase98.HBaseQueueRegionObserver

All Implemented Interfaces:

org.apache.hadoop.hbase.Coprocessor, org.apache.hadoop.hbase.coprocessor.RegionObserver

public final class HBaseQueueRegionObserver
extends org.apache.hadoop.hbase.coprocessor.BaseRegionObserver

RegionObserver for queue table. This class should only have JSE and HBase classes dependencies only. It can also has dependencies on CDAP classes provided that all the transitive dependencies stay within the mentioned scope. This region observer does queue eviction during flush time and compact time by using queue consumer state information to determine if a queue entry row can be omitted during flush/compact.

Nested Class Summary

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

org.apache.hadoop.hbase.coprocessor.RegionObserver.MutationType

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

org.apache.hadoop.hbase.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
HBaseQueueRegionObserver()

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hadoop.hbase.regionserver.InternalScanner	preCompact(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, org.apache.hadoop.hbase.regionserver.Store store, org.apache.hadoop.hbase.regionserver.InternalScanner scanner, org.apache.hadoop.hbase.regionserver.ScanType type, org.apache.hadoop.hbase.regionserver.compactions.CompactionRequest request)
org.apache.hadoop.hbase.regionserver.InternalScanner	preFlush(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, org.apache.hadoop.hbase.regionserver.Store store, org.apache.hadoop.hbase.regionserver.InternalScanner scanner)
void	start(org.apache.hadoop.hbase.CoprocessorEnvironment env)

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

HBaseQueueRegionObserver

public HBaseQueueRegionObserver()

Method Detail

start

public void start(org.apache.hadoop.hbase.CoprocessorEnvironment env)

Specified by:

start in interface org.apache.hadoop.hbase.Coprocessor

Overrides:

start in class org.apache.hadoop.hbase.coprocessor.BaseRegionObserver

preFlush

public org.apache.hadoop.hbase.regionserver.InternalScanner preFlush(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e,
                                                            org.apache.hadoop.hbase.regionserver.Store store,
                                                            org.apache.hadoop.hbase.regionserver.InternalScanner scanner)
                                                              throws IOException

Specified by:

preFlush in interface org.apache.hadoop.hbase.coprocessor.RegionObserver

Overrides:

preFlush in class org.apache.hadoop.hbase.coprocessor.BaseRegionObserver

Throws:

IOException

preCompact

public org.apache.hadoop.hbase.regionserver.InternalScanner preCompact(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e,
                                                              org.apache.hadoop.hbase.regionserver.Store store,
                                                              org.apache.hadoop.hbase.regionserver.InternalScanner scanner,
                                                              org.apache.hadoop.hbase.regionserver.ScanType type,
                                                              org.apache.hadoop.hbase.regionserver.compactions.CompactionRequest request)
                                                                throws IOException

Specified by:

preCompact in interface org.apache.hadoop.hbase.coprocessor.RegionObserver

Overrides:

preCompact in class org.apache.hadoop.hbase.coprocessor.BaseRegionObserver

Throws:

IOException