org.apache.hadoop.hbase.coprocessor

Class SimpleRegionObserver

java.lang.Object

org.apache.hadoop.hbase.coprocessor.SimpleRegionObserver

All Implemented Interfaces:

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

Direct Known Subclasses:

TestCoprocessorHost.SimpleRegionObserverV2, TestIncrementTimeRange.MyObserver, TestNegativeMemStoreSizeWithSlowCoprocessor.FlushingRegionObserver, TestRegionServerCoprocessorExceptionWithAbort.BuggyRegionObserver, TestRegionServerCoprocessorExceptionWithRemove.BuggyRegionObserver

public class SimpleRegionObserver
extends Object
implements org.apache.hadoop.hbase.coprocessor.RegionCoprocessor, org.apache.hadoop.hbase.coprocessor.RegionObserver

A sample region observer that tests the RegionObserver interface. It works with TestRegionObserverInterface to provide the test case.

Nested Class Summary

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

org.apache.hadoop.hbase.Coprocessor.State

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

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

Field Summary

Fields

Modifier and Type	Field and Description
(package private) AtomicInteger	ctBeforeDelete
(package private) AtomicInteger	ctPostAppend
(package private) AtomicInteger	ctPostBatchMutate
(package private) AtomicInteger	ctPostBatchMutateIndispensably
(package private) AtomicInteger	ctPostBulkLoadHFile
(package private) AtomicInteger	ctPostCheckAndDelete
(package private) AtomicInteger	ctPostCheckAndPut
(package private) AtomicInteger	ctPostClose
(package private) AtomicInteger	ctPostCloseRegionOperation
(package private) AtomicInteger	ctPostCompact
(package private) AtomicInteger	ctPostCompactSelect
(package private) AtomicInteger	ctPostDeleted
(package private) AtomicInteger	ctPostFlush
(package private) AtomicInteger	ctPostGet
(package private) AtomicInteger	ctPostIncrement
(package private) AtomicInteger	ctPostOpen
(package private) AtomicInteger	ctPostPut
(package private) AtomicInteger	ctPostReplayWALs
(package private) AtomicInteger	ctPostScannerClose
(package private) AtomicInteger	ctPostScannerFilterRow
(package private) AtomicInteger	ctPostScannerNext
(package private) AtomicInteger	ctPostScannerOpen
(package private) AtomicInteger	ctPostStartRegionOperation
(package private) AtomicInteger	ctPostStoreFileReaderOpen
(package private) AtomicInteger	ctPostWALRestore
(package private) AtomicInteger	ctPreAppend
(package private) AtomicInteger	ctPreAppendAfterRowLock
(package private) AtomicInteger	ctPreBatchMutate
(package private) AtomicInteger	ctPreBulkLoadHFile
(package private) AtomicInteger	ctPreCheckAndDelete
(package private) AtomicInteger	ctPreCheckAndDeleteAfterRowLock
(package private) AtomicInteger	ctPreCheckAndPut
(package private) AtomicInteger	ctPreCheckAndPutAfterRowLock
(package private) AtomicInteger	ctPreClose
(package private) AtomicInteger	ctPreCompact
(package private) AtomicInteger	ctPreCompactSelect
(package private) AtomicInteger	ctPreDeleted
(package private) AtomicInteger	ctPreFlush
(package private) AtomicInteger	ctPreGet
(package private) AtomicInteger	ctPreIncrement
(package private) AtomicInteger	ctPreIncrementAfterRowLock
(package private) AtomicInteger	ctPreOpen
(package private) AtomicInteger	ctPrePrepareDeleteTS
(package private) AtomicInteger	ctPrePut
(package private) AtomicInteger	ctPreReplayWALs
(package private) AtomicInteger	ctPreScannerClose
(package private) AtomicInteger	ctPreScannerNext
(package private) AtomicInteger	ctPreScannerOpen
(package private) AtomicInteger	ctPreStoreFileReaderOpen
(package private) AtomicInteger	ctPreWALRestore
(package private) static String	TABLE_SKIPPED
(package private) AtomicBoolean	throwOnPostFlush

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

PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION

Constructor Summary

Constructors

Constructor and Description
SimpleRegionObserver()

Method Summary

Modifier and Type	Method and Description
int	getCtBeforeDelete()
int	getCtPostClose()
int	getCtPostCloseRegionOperation()
int	getCtPostCompact()
int	getCtPostCompactSelect()
int	getCtPostDeleted()
int	getCtPostFlush()
int	getCtPostGet()
int	getCtPostIncrement()
int	getCtPostOpen()
int	getCtPostPut()
int	getCtPostReplayWALs()
int	getCtPostStartRegionOperation()
int	getCtPostWALRestore()
int	getCtPreClose()
int	getCtPreCompact()
int	getCtPreCompactSelect()
int	getCtPreDeleted()
int	getCtPreFlush()
int	getCtPreGet()
int	getCtPreIncrement()
int	getCtPreOpen()
int	getCtPrePut()
int	getCtPreReplayWALs()
int	getCtPreWALRestore()
Optional<org.apache.hadoop.hbase.coprocessor.RegionObserver>	getRegionObserver()
boolean	hadDelete()
boolean	hadDeleted()
boolean	hadPostAppend()
boolean	hadPostBatchMutate()
boolean	hadPostBatchMutateIndispensably()
boolean	hadPostBulkLoadHFile()
boolean	hadPostCheckAndDelete()
boolean	hadPostCheckAndPut()
boolean	hadPostCloseRegionOperation()
boolean	hadPostGet()
boolean	hadPostIncrement()
boolean	hadPostPut()
boolean	hadPostReplayWALs()
boolean	hadPostStartRegionOperation()
boolean	hadPostWALRestore()
boolean	hadPreAppend()
boolean	hadPreAppendAfterRowLock()
boolean	hadPreBatchMutate()
boolean	hadPreBulkLoadHFile()
boolean	hadPreCheckAndDelete()
boolean	hadPreCheckAndDeleteAfterRowLock()
boolean	hadPreCheckAndPut()
boolean	hadPreCheckAndPutAfterRowLock()
boolean	hadPreGet()
boolean	hadPreIncrement()
boolean	hadPreIncrementAfterRowLock()
boolean	hadPrePreparedDeleteTS()
boolean	hadPrePut()
boolean	hadPreReplayWALs()
boolean	hadPreWALRestore()
org.apache.hadoop.hbase.client.Result	postAppend(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, org.apache.hadoop.hbase.client.Append append, org.apache.hadoop.hbase.client.Result result)
void	postBatchMutate(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.regionserver.MiniBatchOperationInProgress<org.apache.hadoop.hbase.client.Mutation> miniBatchOp)
void	postBatchMutateIndispensably(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> ctx, org.apache.hadoop.hbase.regionserver.MiniBatchOperationInProgress<org.apache.hadoop.hbase.client.Mutation> miniBatchOp, boolean success)
void	postBulkLoadHFile(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> ctx, List<org.apache.hadoop.hbase.util.Pair<byte[],String>> familyPaths, Map<byte[],List<org.apache.hadoop.fs.Path>> map)
boolean	postCheckAndDelete(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, byte[] row, byte[] family, byte[] qualifier, org.apache.hadoop.hbase.CompareOperator compareOp, org.apache.hadoop.hbase.filter.ByteArrayComparable comparator, org.apache.hadoop.hbase.client.Delete delete, boolean result)
boolean	postCheckAndPut(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, byte[] row, byte[] family, byte[] qualifier, org.apache.hadoop.hbase.CompareOperator compareOp, org.apache.hadoop.hbase.filter.ByteArrayComparable comparator, org.apache.hadoop.hbase.client.Put put, boolean result)
void	postClose(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, boolean abortRequested)
void	postCloseRegionOperation(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> ctx, org.apache.hadoop.hbase.regionserver.Region.Operation op)
void	postCompact(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.regionserver.Store store, org.apache.hadoop.hbase.regionserver.StoreFile resultFile, org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker tracker, org.apache.hadoop.hbase.regionserver.compactions.CompactionRequest request)
void	postCompactSelection(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.regionserver.Store store, List<? extends org.apache.hadoop.hbase.regionserver.StoreFile> selected, org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker tracker, org.apache.hadoop.hbase.regionserver.compactions.CompactionRequest request)
void	postDelete(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.client.Delete delete, org.apache.hadoop.hbase.wal.WALEdit edit, org.apache.hadoop.hbase.client.Durability durability)
void	postFlush(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.regionserver.Store store, org.apache.hadoop.hbase.regionserver.StoreFile resultFile, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
void	postGetOp(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.client.Get get, List<org.apache.hadoop.hbase.Cell> results)
org.apache.hadoop.hbase.client.Result	postIncrement(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.client.Increment increment, org.apache.hadoop.hbase.client.Result result)
void	postOpen(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c)
void	postPut(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.client.Put put, org.apache.hadoop.hbase.wal.WALEdit edit, org.apache.hadoop.hbase.client.Durability durability)
void	postReplayWALs(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> env, org.apache.hadoop.hbase.client.RegionInfo info, org.apache.hadoop.fs.Path edits)
void	postScannerClose(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.regionserver.InternalScanner s)
boolean	postScannerFilterRow(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, org.apache.hadoop.hbase.regionserver.InternalScanner s, org.apache.hadoop.hbase.Cell currentRow, boolean hasMore)
boolean	postScannerNext(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.regionserver.InternalScanner s, List<org.apache.hadoop.hbase.client.Result> results, int limit, boolean hasMore)
org.apache.hadoop.hbase.regionserver.RegionScanner	postScannerOpen(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.client.Scan scan, org.apache.hadoop.hbase.regionserver.RegionScanner s)
void	postStartRegionOperation(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> ctx, org.apache.hadoop.hbase.regionserver.Region.Operation op)
org.apache.hadoop.hbase.regionserver.StoreFileReader	postStoreFileReaderOpen(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> ctx, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path p, org.apache.hadoop.hbase.io.FSDataInputStreamWrapper in, long size, org.apache.hadoop.hbase.io.hfile.CacheConfig cacheConf, org.apache.hadoop.hbase.io.Reference r, org.apache.hadoop.hbase.regionserver.StoreFileReader reader)
void	postWALRestore(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> env, org.apache.hadoop.hbase.client.RegionInfo info, org.apache.hadoop.hbase.wal.WALKey logKey, org.apache.hadoop.hbase.wal.WALEdit logEdit)
org.apache.hadoop.hbase.client.Result	preAppend(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, org.apache.hadoop.hbase.client.Append append)
org.apache.hadoop.hbase.client.Result	preAppendAfterRowLock(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, org.apache.hadoop.hbase.client.Append append)
void	preBatchMutate(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.regionserver.MiniBatchOperationInProgress<org.apache.hadoop.hbase.client.Mutation> miniBatchOp)
void	preBulkLoadHFile(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> ctx, List<org.apache.hadoop.hbase.util.Pair<byte[],String>> familyPaths)
boolean	preCheckAndDelete(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, byte[] row, byte[] family, byte[] qualifier, org.apache.hadoop.hbase.CompareOperator compareOp, org.apache.hadoop.hbase.filter.ByteArrayComparable comparator, org.apache.hadoop.hbase.client.Delete delete, boolean result)
boolean	preCheckAndDeleteAfterRowLock(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, byte[] row, byte[] family, byte[] qualifier, org.apache.hadoop.hbase.CompareOperator compareOp, org.apache.hadoop.hbase.filter.ByteArrayComparable comparator, org.apache.hadoop.hbase.client.Delete delete, boolean result)
boolean	preCheckAndPut(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, byte[] row, byte[] family, byte[] qualifier, org.apache.hadoop.hbase.CompareOperator compareOp, org.apache.hadoop.hbase.filter.ByteArrayComparable comparator, org.apache.hadoop.hbase.client.Put put, boolean result)
boolean	preCheckAndPutAfterRowLock(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, byte[] row, byte[] family, byte[] qualifier, org.apache.hadoop.hbase.CompareOperator compareOp, org.apache.hadoop.hbase.filter.ByteArrayComparable comparator, org.apache.hadoop.hbase.client.Put put, boolean result)
void	preClose(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, boolean abortRequested)
org.apache.hadoop.hbase.regionserver.InternalScanner	preCompact(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.regionserver.Store store, org.apache.hadoop.hbase.regionserver.InternalScanner scanner, org.apache.hadoop.hbase.regionserver.ScanType scanType, org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker tracker, org.apache.hadoop.hbase.regionserver.compactions.CompactionRequest request)
void	preCompactSelection(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.regionserver.Store store, List<? extends org.apache.hadoop.hbase.regionserver.StoreFile> candidates, org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker tracker)
void	preDelete(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.client.Delete delete, org.apache.hadoop.hbase.wal.WALEdit edit, org.apache.hadoop.hbase.client.Durability durability)
org.apache.hadoop.hbase.regionserver.InternalScanner	preFlush(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.regionserver.Store store, org.apache.hadoop.hbase.regionserver.InternalScanner scanner, org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
void	preGetOp(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.client.Get get, List<org.apache.hadoop.hbase.Cell> results)
org.apache.hadoop.hbase.client.Result	preIncrement(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.client.Increment increment)
org.apache.hadoop.hbase.client.Result	preIncrementAfterRowLock(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, org.apache.hadoop.hbase.client.Increment increment)
void	preOpen(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c)
void	prePrepareTimeStampForDeleteVersion(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, org.apache.hadoop.hbase.client.Mutation delete, org.apache.hadoop.hbase.Cell cell, byte[] byteNow, org.apache.hadoop.hbase.client.Get get)
void	prePut(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.client.Put put, org.apache.hadoop.hbase.wal.WALEdit edit, org.apache.hadoop.hbase.client.Durability durability)
void	preReplayWALs(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> env, org.apache.hadoop.hbase.client.RegionInfo info, org.apache.hadoop.fs.Path edits)
void	preScannerClose(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.regionserver.InternalScanner s)
boolean	preScannerNext(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.regionserver.InternalScanner s, List<org.apache.hadoop.hbase.client.Result> results, int limit, boolean hasMore)
void	preScannerOpen(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.client.Scan scan)
org.apache.hadoop.hbase.regionserver.StoreFileReader	preStoreFileReaderOpen(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> ctx, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path p, org.apache.hadoop.hbase.io.FSDataInputStreamWrapper in, long size, org.apache.hadoop.hbase.io.hfile.CacheConfig cacheConf, org.apache.hadoop.hbase.io.Reference r, org.apache.hadoop.hbase.regionserver.StoreFileReader reader)
void	preWALRestore(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> env, org.apache.hadoop.hbase.client.RegionInfo info, org.apache.hadoop.hbase.wal.WALKey logKey, org.apache.hadoop.hbase.wal.WALEdit logEdit)
void	setThrowOnPostFlush(Boolean val)
void	start(org.apache.hadoop.hbase.CoprocessorEnvironment e)
boolean	wasClosed()
boolean	wasCompacted()
boolean	wasFlushed()
boolean	wasOpened()
boolean	wasScannerCloseCalled()
boolean	wasScannerFilterRowCalled()
boolean	wasScannerNextCalled()
boolean	wasScannerOpenCalled()
boolean	wasStoreFileReaderOpenCalled()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.coprocessor.RegionCoprocessor

getBulkLoadObserver, getEndpointObserver

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

getServices, stop

Methods inherited from interface org.apache.hadoop.hbase.coprocessor.RegionObserver

postCommitStoreFile, postExists, postFlush, postInstantiateDeleteTracker, postMemStoreCompaction, postMutationBeforeWAL, preCommitStoreFile, preCompactScannerOpen, preExists, preFlush, preFlushScannerOpen, preMemStoreCompaction, preMemStoreCompactionCompact, preMemStoreCompactionCompactScannerOpen, preStoreScannerOpen

Field Detail

ctBeforeDelete

final AtomicInteger ctBeforeDelete

ctPreOpen

final AtomicInteger ctPreOpen

ctPostOpen

final AtomicInteger ctPostOpen

ctPreClose

final AtomicInteger ctPreClose

ctPostClose

final AtomicInteger ctPostClose

ctPreFlush

final AtomicInteger ctPreFlush

ctPostFlush

final AtomicInteger ctPostFlush

ctPreCompactSelect

final AtomicInteger ctPreCompactSelect

ctPostCompactSelect

final AtomicInteger ctPostCompactSelect

ctPreCompact

final AtomicInteger ctPreCompact

ctPostCompact

final AtomicInteger ctPostCompact

ctPreGet

final AtomicInteger ctPreGet

ctPostGet

final AtomicInteger ctPostGet

ctPrePut

final AtomicInteger ctPrePut

ctPostPut

final AtomicInteger ctPostPut

ctPreDeleted

final AtomicInteger ctPreDeleted

ctPrePrepareDeleteTS

final AtomicInteger ctPrePrepareDeleteTS

ctPostDeleted

final AtomicInteger ctPostDeleted

ctPreIncrement

final AtomicInteger ctPreIncrement

ctPreIncrementAfterRowLock

final AtomicInteger ctPreIncrementAfterRowLock

ctPreAppend

final AtomicInteger ctPreAppend

ctPreAppendAfterRowLock

final AtomicInteger ctPreAppendAfterRowLock

ctPostIncrement

final AtomicInteger ctPostIncrement

ctPostAppend

final AtomicInteger ctPostAppend

ctPreCheckAndPut

final AtomicInteger ctPreCheckAndPut

ctPreCheckAndPutAfterRowLock

final AtomicInteger ctPreCheckAndPutAfterRowLock

ctPostCheckAndPut

final AtomicInteger ctPostCheckAndPut

ctPreCheckAndDelete

final AtomicInteger ctPreCheckAndDelete

ctPreCheckAndDeleteAfterRowLock

final AtomicInteger ctPreCheckAndDeleteAfterRowLock

ctPostCheckAndDelete

final AtomicInteger ctPostCheckAndDelete

ctPreScannerNext

final AtomicInteger ctPreScannerNext

ctPostScannerNext

final AtomicInteger ctPostScannerNext

ctPostScannerFilterRow

final AtomicInteger ctPostScannerFilterRow

ctPreScannerClose

final AtomicInteger ctPreScannerClose

ctPostScannerClose

final AtomicInteger ctPostScannerClose

ctPreScannerOpen

final AtomicInteger ctPreScannerOpen

ctPostScannerOpen

final AtomicInteger ctPostScannerOpen

ctPreBulkLoadHFile

final AtomicInteger ctPreBulkLoadHFile

ctPostBulkLoadHFile

final AtomicInteger ctPostBulkLoadHFile

ctPreBatchMutate

final AtomicInteger ctPreBatchMutate

ctPostBatchMutate

final AtomicInteger ctPostBatchMutate

ctPreReplayWALs

final AtomicInteger ctPreReplayWALs

ctPostReplayWALs

final AtomicInteger ctPostReplayWALs

ctPreWALRestore

final AtomicInteger ctPreWALRestore

ctPostWALRestore

final AtomicInteger ctPostWALRestore

ctPreStoreFileReaderOpen

final AtomicInteger ctPreStoreFileReaderOpen

ctPostStoreFileReaderOpen

final AtomicInteger ctPostStoreFileReaderOpen

ctPostBatchMutateIndispensably

final AtomicInteger ctPostBatchMutateIndispensably

ctPostStartRegionOperation

final AtomicInteger ctPostStartRegionOperation

ctPostCloseRegionOperation

final AtomicInteger ctPostCloseRegionOperation

throwOnPostFlush

final AtomicBoolean throwOnPostFlush

TABLE_SKIPPED

static final String TABLE_SKIPPED

See Also:

Constant Field Values

Constructor Detail

SimpleRegionObserver

public SimpleRegionObserver()

Method Detail

setThrowOnPostFlush

public void setThrowOnPostFlush(Boolean val)

getRegionObserver

public Optional<org.apache.hadoop.hbase.coprocessor.RegionObserver> getRegionObserver()

Specified by:

getRegionObserver in interface org.apache.hadoop.hbase.coprocessor.RegionCoprocessor

start

public void start(org.apache.hadoop.hbase.CoprocessorEnvironment e)
           throws IOException

Specified by:

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

Throws:

IOException

preOpen

public void preOpen(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c)

Specified by:

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

postOpen

public void postOpen(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c)

Specified by:

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

wasOpened

public boolean wasOpened()

preClose

public void preClose(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
                     boolean abortRequested)

Specified by:

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

postClose

public void postClose(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
                      boolean abortRequested)

Specified by:

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

wasClosed

public boolean wasClosed()

preFlush

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

Specified by:

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

Throws:

IOException

postFlush

public void postFlush(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
                      org.apache.hadoop.hbase.regionserver.Store store,
                      org.apache.hadoop.hbase.regionserver.StoreFile resultFile,
                      org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
               throws IOException

Specified by:

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

Throws:

IOException

wasFlushed

public boolean wasFlushed()

preCompactSelection

public void preCompactSelection(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
                                org.apache.hadoop.hbase.regionserver.Store store,
                                List<? extends org.apache.hadoop.hbase.regionserver.StoreFile> candidates,
                                org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker tracker)
                         throws IOException

Specified by:

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

Throws:

IOException

postCompactSelection

public void postCompactSelection(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
                                 org.apache.hadoop.hbase.regionserver.Store store,
                                 List<? extends org.apache.hadoop.hbase.regionserver.StoreFile> selected,
                                 org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker tracker,
                                 org.apache.hadoop.hbase.regionserver.compactions.CompactionRequest request)

Specified by:

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

preCompact

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

Specified by:

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

Throws:

IOException

postCompact

public void postCompact(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
                        org.apache.hadoop.hbase.regionserver.Store store,
                        org.apache.hadoop.hbase.regionserver.StoreFile resultFile,
                        org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker tracker,
                        org.apache.hadoop.hbase.regionserver.compactions.CompactionRequest request)
                 throws IOException

Specified by:

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

Throws:

IOException

wasCompacted

public boolean wasCompacted()

preScannerOpen

public void preScannerOpen(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
                           org.apache.hadoop.hbase.client.Scan scan)
                    throws IOException

Specified by:

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

Throws:

IOException

postScannerOpen

public org.apache.hadoop.hbase.regionserver.RegionScanner postScannerOpen(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
                                                                          org.apache.hadoop.hbase.client.Scan scan,
                                                                          org.apache.hadoop.hbase.regionserver.RegionScanner s)
                                                                   throws IOException

Specified by:

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

Throws:

IOException

preScannerNext

public boolean preScannerNext(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
                              org.apache.hadoop.hbase.regionserver.InternalScanner s,
                              List<org.apache.hadoop.hbase.client.Result> results,
                              int limit,
                              boolean hasMore)
                       throws IOException

Specified by:

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

Throws:

IOException

postScannerNext

public boolean postScannerNext(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
                               org.apache.hadoop.hbase.regionserver.InternalScanner s,
                               List<org.apache.hadoop.hbase.client.Result> results,
                               int limit,
                               boolean hasMore)
                        throws IOException

Specified by:

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

Throws:

IOException

postScannerFilterRow

public boolean postScannerFilterRow(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e,
                                    org.apache.hadoop.hbase.regionserver.InternalScanner s,
                                    org.apache.hadoop.hbase.Cell currentRow,
                                    boolean hasMore)
                             throws IOException

Specified by:

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

Throws:

IOException

preScannerClose

public void preScannerClose(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
                            org.apache.hadoop.hbase.regionserver.InternalScanner s)
                     throws IOException

Specified by:

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

Throws:

IOException

postScannerClose

public void postScannerClose(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
                             org.apache.hadoop.hbase.regionserver.InternalScanner s)
                      throws IOException

Specified by:

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

Throws:

IOException

preGetOp

public void preGetOp(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
                     org.apache.hadoop.hbase.client.Get get,
                     List<org.apache.hadoop.hbase.Cell> results)
              throws IOException

Specified by:

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

Throws:

IOException

postGetOp

public void postGetOp(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
                      org.apache.hadoop.hbase.client.Get get,
                      List<org.apache.hadoop.hbase.Cell> results)

Specified by:

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

prePut

public void prePut(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
                   org.apache.hadoop.hbase.client.Put put,
                   org.apache.hadoop.hbase.wal.WALEdit edit,
                   org.apache.hadoop.hbase.client.Durability durability)
            throws IOException

Specified by:

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

Throws:

IOException

postPut

public void postPut(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
                    org.apache.hadoop.hbase.client.Put put,
                    org.apache.hadoop.hbase.wal.WALEdit edit,
                    org.apache.hadoop.hbase.client.Durability durability)
             throws IOException

Specified by:

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

Throws:

IOException

preDelete

public void preDelete(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
                      org.apache.hadoop.hbase.client.Delete delete,
                      org.apache.hadoop.hbase.wal.WALEdit edit,
                      org.apache.hadoop.hbase.client.Durability durability)
               throws IOException

Specified by:

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

Throws:

IOException

prePrepareTimeStampForDeleteVersion

public void prePrepareTimeStampForDeleteVersion(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e,
                                                org.apache.hadoop.hbase.client.Mutation delete,
                                                org.apache.hadoop.hbase.Cell cell,
                                                byte[] byteNow,
                                                org.apache.hadoop.hbase.client.Get get)
                                         throws IOException

Specified by:

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

Throws:

IOException

postDelete

public void postDelete(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
                       org.apache.hadoop.hbase.client.Delete delete,
                       org.apache.hadoop.hbase.wal.WALEdit edit,
                       org.apache.hadoop.hbase.client.Durability durability)
                throws IOException

Specified by:

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

Throws:

IOException

preBatchMutate

public void preBatchMutate(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
                           org.apache.hadoop.hbase.regionserver.MiniBatchOperationInProgress<org.apache.hadoop.hbase.client.Mutation> miniBatchOp)
                    throws IOException

Specified by:

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

Throws:

IOException

postBatchMutate

public void postBatchMutate(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
                            org.apache.hadoop.hbase.regionserver.MiniBatchOperationInProgress<org.apache.hadoop.hbase.client.Mutation> miniBatchOp)
                     throws IOException

Specified by:

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

Throws:

IOException

postStartRegionOperation

public void postStartRegionOperation(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> ctx,
                                     org.apache.hadoop.hbase.regionserver.Region.Operation op)
                              throws IOException

Specified by:

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

Throws:

IOException

postCloseRegionOperation

public void postCloseRegionOperation(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> ctx,
                                     org.apache.hadoop.hbase.regionserver.Region.Operation op)
                              throws IOException

Specified by:

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

Throws:

IOException

postBatchMutateIndispensably

public void postBatchMutateIndispensably(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> ctx,
                                         org.apache.hadoop.hbase.regionserver.MiniBatchOperationInProgress<org.apache.hadoop.hbase.client.Mutation> miniBatchOp,
                                         boolean success)
                                  throws IOException

Specified by:

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

Throws:

IOException

preIncrement

public org.apache.hadoop.hbase.client.Result preIncrement(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
                                                          org.apache.hadoop.hbase.client.Increment increment)
                                                   throws IOException

Specified by:

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

Throws:

IOException

preIncrementAfterRowLock

public org.apache.hadoop.hbase.client.Result preIncrementAfterRowLock(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e,
                                                                      org.apache.hadoop.hbase.client.Increment increment)
                                                               throws IOException

Specified by:

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

Throws:

IOException

postIncrement

public org.apache.hadoop.hbase.client.Result postIncrement(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
                                                           org.apache.hadoop.hbase.client.Increment increment,
                                                           org.apache.hadoop.hbase.client.Result result)
                                                    throws IOException

Specified by:

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

Throws:

IOException

preCheckAndPut

public boolean preCheckAndPut(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e,
                              byte[] row,
                              byte[] family,
                              byte[] qualifier,
                              org.apache.hadoop.hbase.CompareOperator compareOp,
                              org.apache.hadoop.hbase.filter.ByteArrayComparable comparator,
                              org.apache.hadoop.hbase.client.Put put,
                              boolean result)
                       throws IOException

Specified by:

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

Throws:

IOException

preCheckAndPutAfterRowLock

public boolean preCheckAndPutAfterRowLock(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e,
                                          byte[] row,
                                          byte[] family,
                                          byte[] qualifier,
                                          org.apache.hadoop.hbase.CompareOperator compareOp,
                                          org.apache.hadoop.hbase.filter.ByteArrayComparable comparator,
                                          org.apache.hadoop.hbase.client.Put put,
                                          boolean result)
                                   throws IOException

Specified by:

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

Throws:

IOException

postCheckAndPut

public boolean postCheckAndPut(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e,
                               byte[] row,
                               byte[] family,
                               byte[] qualifier,
                               org.apache.hadoop.hbase.CompareOperator compareOp,
                               org.apache.hadoop.hbase.filter.ByteArrayComparable comparator,
                               org.apache.hadoop.hbase.client.Put put,
                               boolean result)
                        throws IOException

Specified by:

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

Throws:

IOException

preCheckAndDelete

public boolean preCheckAndDelete(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e,
                                 byte[] row,
                                 byte[] family,
                                 byte[] qualifier,
                                 org.apache.hadoop.hbase.CompareOperator compareOp,
                                 org.apache.hadoop.hbase.filter.ByteArrayComparable comparator,
                                 org.apache.hadoop.hbase.client.Delete delete,
                                 boolean result)
                          throws IOException

Specified by:

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

Throws:

IOException

preCheckAndDeleteAfterRowLock

public boolean preCheckAndDeleteAfterRowLock(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e,
                                             byte[] row,
                                             byte[] family,
                                             byte[] qualifier,
                                             org.apache.hadoop.hbase.CompareOperator compareOp,
                                             org.apache.hadoop.hbase.filter.ByteArrayComparable comparator,
                                             org.apache.hadoop.hbase.client.Delete delete,
                                             boolean result)
                                      throws IOException

Specified by:

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

Throws:

IOException

postCheckAndDelete

public boolean postCheckAndDelete(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e,
                                  byte[] row,
                                  byte[] family,
                                  byte[] qualifier,
                                  org.apache.hadoop.hbase.CompareOperator compareOp,
                                  org.apache.hadoop.hbase.filter.ByteArrayComparable comparator,
                                  org.apache.hadoop.hbase.client.Delete delete,
                                  boolean result)
                           throws IOException

Specified by:

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

Throws:

IOException

preAppendAfterRowLock

public org.apache.hadoop.hbase.client.Result preAppendAfterRowLock(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e,
                                                                   org.apache.hadoop.hbase.client.Append append)
                                                            throws IOException

Specified by:

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

Throws:

IOException

preAppend

public org.apache.hadoop.hbase.client.Result preAppend(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e,
                                                       org.apache.hadoop.hbase.client.Append append)
                                                throws IOException

Specified by:

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

Throws:

IOException

postAppend

public org.apache.hadoop.hbase.client.Result postAppend(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e,
                                                        org.apache.hadoop.hbase.client.Append append,
                                                        org.apache.hadoop.hbase.client.Result result)
                                                 throws IOException

Specified by:

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

Throws:

IOException

preBulkLoadHFile

public void preBulkLoadHFile(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> ctx,
                             List<org.apache.hadoop.hbase.util.Pair<byte[],String>> familyPaths)
                      throws IOException

Specified by:

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

Throws:

IOException

postBulkLoadHFile

public void postBulkLoadHFile(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> ctx,
                              List<org.apache.hadoop.hbase.util.Pair<byte[],String>> familyPaths,
                              Map<byte[],List<org.apache.hadoop.fs.Path>> map)
                       throws IOException

Specified by:

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

Throws:

IOException

preReplayWALs

public void preReplayWALs(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> env,
                          org.apache.hadoop.hbase.client.RegionInfo info,
                          org.apache.hadoop.fs.Path edits)
                   throws IOException

Specified by:

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

Throws:

IOException

postReplayWALs

public void postReplayWALs(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> env,
                           org.apache.hadoop.hbase.client.RegionInfo info,
                           org.apache.hadoop.fs.Path edits)
                    throws IOException

Specified by:

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

Throws:

IOException

preWALRestore

public void preWALRestore(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> env,
                          org.apache.hadoop.hbase.client.RegionInfo info,
                          org.apache.hadoop.hbase.wal.WALKey logKey,
                          org.apache.hadoop.hbase.wal.WALEdit logEdit)
                   throws IOException

Specified by:

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

Throws:

IOException

postWALRestore

public void postWALRestore(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> env,
                           org.apache.hadoop.hbase.client.RegionInfo info,
                           org.apache.hadoop.hbase.wal.WALKey logKey,
                           org.apache.hadoop.hbase.wal.WALEdit logEdit)
                    throws IOException

Specified by:

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

Throws:

IOException

preStoreFileReaderOpen

public org.apache.hadoop.hbase.regionserver.StoreFileReader preStoreFileReaderOpen(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> ctx,
                                                                                   org.apache.hadoop.fs.FileSystem fs,
                                                                                   org.apache.hadoop.fs.Path p,
                                                                                   org.apache.hadoop.hbase.io.FSDataInputStreamWrapper in,
                                                                                   long size,
                                                                                   org.apache.hadoop.hbase.io.hfile.CacheConfig cacheConf,
                                                                                   org.apache.hadoop.hbase.io.Reference r,
                                                                                   org.apache.hadoop.hbase.regionserver.StoreFileReader reader)
                                                                            throws IOException

Specified by:

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

Throws:

IOException

postStoreFileReaderOpen

public org.apache.hadoop.hbase.regionserver.StoreFileReader postStoreFileReaderOpen(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> ctx,
                                                                                    org.apache.hadoop.fs.FileSystem fs,
                                                                                    org.apache.hadoop.fs.Path p,
                                                                                    org.apache.hadoop.hbase.io.FSDataInputStreamWrapper in,
                                                                                    long size,
                                                                                    org.apache.hadoop.hbase.io.hfile.CacheConfig cacheConf,
                                                                                    org.apache.hadoop.hbase.io.Reference r,
                                                                                    org.apache.hadoop.hbase.regionserver.StoreFileReader reader)
                                                                             throws IOException

Specified by:

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

Throws:

IOException

hadPreGet

public boolean hadPreGet()

hadPostGet

public boolean hadPostGet()

hadPrePut

public boolean hadPrePut()

hadPostPut

public boolean hadPostPut()

hadPreBatchMutate

public boolean hadPreBatchMutate()

hadPostBatchMutate

public boolean hadPostBatchMutate()

hadPostBatchMutateIndispensably

public boolean hadPostBatchMutateIndispensably()

hadPostStartRegionOperation

public boolean hadPostStartRegionOperation()

hadPostCloseRegionOperation

public boolean hadPostCloseRegionOperation()

hadDelete

public boolean hadDelete()

getCtPostStartRegionOperation

public int getCtPostStartRegionOperation()

getCtPostCloseRegionOperation

public int getCtPostCloseRegionOperation()

hadPreCheckAndPut

public boolean hadPreCheckAndPut()

hadPreCheckAndPutAfterRowLock

public boolean hadPreCheckAndPutAfterRowLock()

hadPostCheckAndPut

public boolean hadPostCheckAndPut()

hadPreCheckAndDelete

public boolean hadPreCheckAndDelete()

hadPreCheckAndDeleteAfterRowLock

public boolean hadPreCheckAndDeleteAfterRowLock()

hadPostCheckAndDelete

public boolean hadPostCheckAndDelete()

hadPreIncrement

public boolean hadPreIncrement()

hadPreIncrementAfterRowLock

public boolean hadPreIncrementAfterRowLock()

hadPostIncrement

public boolean hadPostIncrement()

hadPreAppend

public boolean hadPreAppend()

hadPreAppendAfterRowLock

public boolean hadPreAppendAfterRowLock()

hadPostAppend

public boolean hadPostAppend()

hadPrePreparedDeleteTS

public boolean hadPrePreparedDeleteTS()

hadPreReplayWALs

public boolean hadPreReplayWALs()

hadPostReplayWALs

public boolean hadPostReplayWALs()

hadPreWALRestore

public boolean hadPreWALRestore()

hadPostWALRestore

public boolean hadPostWALRestore()

wasScannerNextCalled

public boolean wasScannerNextCalled()

wasScannerFilterRowCalled

public boolean wasScannerFilterRowCalled()

wasScannerCloseCalled

public boolean wasScannerCloseCalled()

wasScannerOpenCalled

public boolean wasScannerOpenCalled()

hadDeleted

public boolean hadDeleted()

hadPostBulkLoadHFile

public boolean hadPostBulkLoadHFile()

hadPreBulkLoadHFile

public boolean hadPreBulkLoadHFile()

getCtBeforeDelete

public int getCtBeforeDelete()

getCtPreOpen

public int getCtPreOpen()

getCtPostOpen

public int getCtPostOpen()

getCtPreClose

public int getCtPreClose()

getCtPostClose

public int getCtPostClose()

getCtPreFlush

public int getCtPreFlush()

getCtPostFlush

public int getCtPostFlush()

getCtPreCompactSelect

public int getCtPreCompactSelect()

getCtPostCompactSelect

public int getCtPostCompactSelect()

getCtPreCompact

public int getCtPreCompact()

getCtPostCompact

public int getCtPostCompact()

getCtPreGet

public int getCtPreGet()

getCtPostGet

public int getCtPostGet()

getCtPrePut

public int getCtPrePut()

getCtPostPut

public int getCtPostPut()

getCtPreDeleted

public int getCtPreDeleted()

getCtPostDeleted

public int getCtPostDeleted()

getCtPreIncrement

public int getCtPreIncrement()

getCtPostIncrement

public int getCtPostIncrement()

getCtPreReplayWALs

public int getCtPreReplayWALs()

getCtPostReplayWALs

public int getCtPostReplayWALs()

getCtPreWALRestore

public int getCtPreWALRestore()

getCtPostWALRestore

public int getCtPostWALRestore()

wasStoreFileReaderOpenCalled

public boolean wasStoreFileReaderOpenCalled()