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, TestCoprocessorHost.SimpleRegionObserverV3, 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	ctPostCheckAndDeleteWithFilter
(package private) AtomicInteger	ctPostCheckAndPut
(package private) AtomicInteger	ctPostCheckAndPutWithFilter
(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	ctPreCheckAndDeleteWithFilter
(package private) AtomicInteger	ctPreCheckAndDeleteWithFilterAfterRowLock
(package private) AtomicInteger	ctPreCheckAndPut
(package private) AtomicInteger	ctPreCheckAndPutAfterRowLock
(package private) AtomicInteger	ctPreCheckAndPutWithFilter
(package private) AtomicInteger	ctPreCheckAndPutWithFilterAfterRowLock
(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	ctPreWALAppend
(package private) AtomicInteger	ctPreWALRestore
(package private) Map<String,byte[]>	extendedAttributes
(package private) static String	TABLE_SKIPPED
(package private) AtomicBoolean	throwOnPostFlush
(package private) static byte[]	WAL_EXTENDED_ATTRIBUTE_BYTES

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	getCtPreWALAppend()
int	getCtPreWALRestore()
int	getPostCheckAndDelete()
int	getPostCheckAndDeleteWithFilter()
int	getPostCheckAndPut()
int	getPostCheckAndPutWithFilter()
int	getPreCheckAndDelete()
int	getPreCheckAndDeleteAfterRowLock()
int	getPreCheckAndDeleteWithFilter()
int	getPreCheckAndDeleteWithFilterAfterRowLock()
int	getPreCheckAndPut()
int	getPreCheckAndPutAfterRowLock()
int	getPreCheckAndPutWithFilter()
int	getPreCheckAndPutWithFilterAfterRowLock()
Optional<org.apache.hadoop.hbase.coprocessor.RegionObserver>	getRegionObserver()
boolean	hadDelete()
boolean	hadDeleted()
boolean	hadPostAppend()
boolean	hadPostBatchMutate()
boolean	hadPostBatchMutateIndispensably()
boolean	hadPostBulkLoadHFile()
boolean	hadPostCloseRegionOperation()
boolean	hadPostGet()
boolean	hadPostIncrement()
boolean	hadPostPut()
boolean	hadPostReplayWALs()
boolean	hadPostStartRegionOperation()
boolean	hadPostWALRestore()
boolean	hadPreAppend()
boolean	hadPreAppendAfterRowLock()
boolean	hadPreBatchMutate()
boolean	hadPreBulkLoadHFile()
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	postCheckAndDelete(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, byte[] row, org.apache.hadoop.hbase.filter.Filter filter, 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)
boolean	postCheckAndPut(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, byte[] row, org.apache.hadoop.hbase.filter.Filter filter, 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	preCheckAndDelete(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, byte[] row, org.apache.hadoop.hbase.filter.Filter filter, 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	preCheckAndDeleteAfterRowLock(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, byte[] row, org.apache.hadoop.hbase.filter.Filter filter, 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	preCheckAndPut(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, byte[] row, org.apache.hadoop.hbase.filter.Filter filter, 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)
boolean	preCheckAndPutAfterRowLock(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, byte[] row, org.apache.hadoop.hbase.filter.Filter filter, 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	preCompactScannerOpen(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.ScanType scanType, org.apache.hadoop.hbase.regionserver.ScanOptions options, 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	preFlushScannerOpen(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.ScanOptions options, 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	preMemStoreCompactionCompactScannerOpen(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.ScanOptions options)
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	preStoreScannerOpen(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> ctx, org.apache.hadoop.hbase.regionserver.Store store, org.apache.hadoop.hbase.regionserver.ScanOptions options)
void	preWALAppend(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> ctx, org.apache.hadoop.hbase.wal.WALKey key, org.apache.hadoop.hbase.wal.WALEdit edit)
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)
private void	setScanOptions(org.apache.hadoop.hbase.regionserver.ScanOptions options)
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

postAppendBeforeWAL, postCommitStoreFile, postExists, postFlush, postIncrementBeforeWAL, postInstantiateDeleteTracker, postMemStoreCompaction, postMutationBeforeWAL, preCommitStoreFile, preExists, preFlush, preMemStoreCompaction, preMemStoreCompactionCompact

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

ctPreCheckAndPutWithFilter

final AtomicInteger ctPreCheckAndPutWithFilter

ctPreCheckAndPutAfterRowLock

final AtomicInteger ctPreCheckAndPutAfterRowLock

ctPreCheckAndPutWithFilterAfterRowLock

final AtomicInteger ctPreCheckAndPutWithFilterAfterRowLock

ctPostCheckAndPut

final AtomicInteger ctPostCheckAndPut

ctPostCheckAndPutWithFilter

final AtomicInteger ctPostCheckAndPutWithFilter

ctPreCheckAndDelete

final AtomicInteger ctPreCheckAndDelete

ctPreCheckAndDeleteWithFilter

final AtomicInteger ctPreCheckAndDeleteWithFilter

ctPreCheckAndDeleteAfterRowLock

final AtomicInteger ctPreCheckAndDeleteAfterRowLock

ctPreCheckAndDeleteWithFilterAfterRowLock

final AtomicInteger ctPreCheckAndDeleteWithFilterAfterRowLock

ctPostCheckAndDelete

final AtomicInteger ctPostCheckAndDelete

ctPostCheckAndDeleteWithFilter

final AtomicInteger ctPostCheckAndDeleteWithFilter

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

ctPreWALAppend

final AtomicInteger ctPreWALAppend

TABLE_SKIPPED

static final String TABLE_SKIPPED

See Also:

Constant Field Values

extendedAttributes

Map<String,byte[]> extendedAttributes

WAL_EXTENDED_ATTRIBUTE_BYTES

static final byte[] WAL_EXTENDED_ATTRIBUTE_BYTES

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

preCheckAndPut

public boolean preCheckAndPut(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
                              byte[] row,
                              org.apache.hadoop.hbase.filter.Filter filter,
                              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

preCheckAndPutAfterRowLock

public boolean preCheckAndPutAfterRowLock(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
                                          byte[] row,
                                          org.apache.hadoop.hbase.filter.Filter filter,
                                          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

postCheckAndPut

public boolean postCheckAndPut(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
                               byte[] row,
                               org.apache.hadoop.hbase.filter.Filter filter,
                               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

preCheckAndDelete

public boolean preCheckAndDelete(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
                                 byte[] row,
                                 org.apache.hadoop.hbase.filter.Filter filter,
                                 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

preCheckAndDeleteAfterRowLock

public boolean preCheckAndDeleteAfterRowLock(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
                                             byte[] row,
                                             org.apache.hadoop.hbase.filter.Filter filter,
                                             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

postCheckAndDelete

public boolean postCheckAndDelete(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e,
                                  byte[] row,
                                  org.apache.hadoop.hbase.filter.Filter filter,
                                  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

preStoreScannerOpen

public void preStoreScannerOpen(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> ctx,
                                org.apache.hadoop.hbase.regionserver.Store store,
                                org.apache.hadoop.hbase.regionserver.ScanOptions options)
                         throws IOException

Specified by:

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

Throws:

IOException

preCompactScannerOpen

public void preCompactScannerOpen(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.ScanType scanType,
                                  org.apache.hadoop.hbase.regionserver.ScanOptions options,
                                  org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker tracker,
                                  org.apache.hadoop.hbase.regionserver.compactions.CompactionRequest request)
                           throws IOException

Specified by:

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

Throws:

IOException

preFlushScannerOpen

public void preFlushScannerOpen(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.ScanOptions options,
                                org.apache.hadoop.hbase.regionserver.FlushLifeCycleTracker tracker)
                         throws IOException

Specified by:

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

Throws:

IOException

preMemStoreCompactionCompactScannerOpen

public void preMemStoreCompactionCompactScannerOpen(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.ScanOptions options)
                                             throws IOException

Specified by:

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

Throws:

IOException

setScanOptions

private void setScanOptions(org.apache.hadoop.hbase.regionserver.ScanOptions options)

preWALAppend

public void preWALAppend(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> ctx,
                         org.apache.hadoop.hbase.wal.WALKey key,
                         org.apache.hadoop.hbase.wal.WALEdit edit)
                  throws IOException

Specified by:

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

getPreCheckAndPut

public int getPreCheckAndPut()

getPreCheckAndPutWithFilter

public int getPreCheckAndPutWithFilter()

getPreCheckAndPutAfterRowLock

public int getPreCheckAndPutAfterRowLock()

getPreCheckAndPutWithFilterAfterRowLock

public int getPreCheckAndPutWithFilterAfterRowLock()

getPostCheckAndPut

public int getPostCheckAndPut()

getPostCheckAndPutWithFilter

public int getPostCheckAndPutWithFilter()

getPreCheckAndDelete

public int getPreCheckAndDelete()

getPreCheckAndDeleteWithFilter

public int getPreCheckAndDeleteWithFilter()

getPreCheckAndDeleteAfterRowLock

public int getPreCheckAndDeleteAfterRowLock()

getPreCheckAndDeleteWithFilterAfterRowLock

public int getPreCheckAndDeleteWithFilterAfterRowLock()

getPostCheckAndDelete

public int getPostCheckAndDelete()

getPostCheckAndDeleteWithFilter

public int getPostCheckAndDeleteWithFilter()

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

getCtPreWALAppend

public int getCtPreWALAppend()

wasStoreFileReaderOpenCalled

public boolean wasStoreFileReaderOpenCalled()