Package 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	Description
(package private) final AtomicInteger	ctBeforeDelete
(package private) final AtomicInteger	ctPostAppend
(package private) final AtomicInteger	ctPostBatchMutate
(package private) final AtomicInteger	ctPostBatchMutateIndispensably
(package private) final AtomicInteger	ctPostBulkLoadHFile
(package private) final AtomicInteger	ctPostCheckAndDelete
(package private) final AtomicInteger	ctPostCheckAndDeleteWithFilter
(package private) final AtomicInteger	ctPostCheckAndMutate
(package private) final AtomicInteger	ctPostCheckAndPut
(package private) final AtomicInteger	ctPostCheckAndPutWithFilter
(package private) final AtomicInteger	ctPostClose
(package private) final AtomicInteger	ctPostCloseRegionOperation
(package private) final AtomicInteger	ctPostCompact
(package private) final AtomicInteger	ctPostCompactSelect
(package private) final AtomicInteger	ctPostDeleted
(package private) final AtomicInteger	ctPostFlush
(package private) final AtomicInteger	ctPostGet
(package private) final AtomicInteger	ctPostIncrement
(package private) final AtomicInteger	ctPostOpen
(package private) final AtomicInteger	ctPostPut
(package private) final AtomicInteger	ctPostReplayWALs
(package private) final AtomicInteger	ctPostScannerClose
(package private) final AtomicInteger	ctPostScannerFilterRow
(package private) final AtomicInteger	ctPostScannerNext
(package private) final AtomicInteger	ctPostScannerOpen
(package private) final AtomicInteger	ctPostStartRegionOperation
(package private) final AtomicInteger	ctPostStoreFileReaderOpen
(package private) final AtomicInteger	ctPreAppend
(package private) final AtomicInteger	ctPreAppendAfterRowLock
(package private) final AtomicInteger	ctPreBatchMutate
(package private) final AtomicInteger	ctPreBulkLoadHFile
(package private) final AtomicInteger	ctPreCheckAndDelete
(package private) final AtomicInteger	ctPreCheckAndDeleteAfterRowLock
(package private) final AtomicInteger	ctPreCheckAndDeleteWithFilter
(package private) final AtomicInteger	ctPreCheckAndDeleteWithFilterAfterRowLock
(package private) final AtomicInteger	ctPreCheckAndMutate
(package private) final AtomicInteger	ctPreCheckAndMutateAfterRowLock
(package private) final AtomicInteger	ctPreCheckAndPut
(package private) final AtomicInteger	ctPreCheckAndPutAfterRowLock
(package private) final AtomicInteger	ctPreCheckAndPutWithFilter
(package private) final AtomicInteger	ctPreCheckAndPutWithFilterAfterRowLock
(package private) final AtomicInteger	ctPreClose
(package private) final AtomicInteger	ctPreCompact
(package private) final AtomicInteger	ctPreCompactSelect
(package private) final AtomicInteger	ctPreDeleted
(package private) final AtomicInteger	ctPreFlush
(package private) final AtomicInteger	ctPreGet
(package private) final AtomicInteger	ctPreIncrement
(package private) final AtomicInteger	ctPreIncrementAfterRowLock
(package private) final AtomicInteger	ctPreOpen
(package private) final AtomicInteger	ctPrePrepareDeleteTS
(package private) final AtomicInteger	ctPrePut
(package private) final AtomicInteger	ctPreReplayWALs
(package private) final AtomicInteger	ctPreScannerClose
(package private) final AtomicInteger	ctPreScannerNext
(package private) final AtomicInteger	ctPreScannerOpen
(package private) final AtomicInteger	ctPreStoreFileReaderOpen
(package private) final AtomicInteger	ctPreWALAppend
(package private) Map<String,byte[]>	extendedAttributes
(package private) static final String	TABLE_SKIPPED
(package private) final AtomicBoolean	throwOnPostFlush
(package private) static final 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	Description
SimpleRegionObserver()

Method Summary

Modifier and Type	Method	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	getCtPreClose()
int	getCtPreCompact()
int	getCtPreCompactSelect()
int	getCtPreDeleted()
int	getCtPreFlush()
int	getCtPreGet()
int	getCtPreIncrement()
int	getCtPreOpen()
int	getCtPrePut()
int	getCtPreReplayWALs()
int	getCtPreWALAppend()
int	getPostBatchMutate()
int	getPostBatchMutateIndispensably()
int	getPostCheckAndDelete()
int	getPostCheckAndDeleteWithFilter()
int	getPostCheckAndMutate()
int	getPostCheckAndPut()
int	getPostCheckAndPutWithFilter()
int	getPreBatchMutate()
int	getPreCheckAndDelete()
int	getPreCheckAndDeleteAfterRowLock()
int	getPreCheckAndDeleteWithFilter()
int	getPreCheckAndDeleteWithFilterAfterRowLock()
int	getPreCheckAndMutate()
int	getPreCheckAndMutateAfterRowLock()
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	hadPreAppend()
boolean	hadPreAppendAfterRowLock()
boolean	hadPreBatchMutate()
boolean	hadPreBulkLoadHFile()
boolean	hadPreGet()
boolean	hadPreIncrement()
boolean	hadPreIncrementAfterRowLock()
boolean	hadPrePreparedDeleteTS()
boolean	hadPrePut()
boolean	hadPreReplayWALs()
org.apache.hadoop.hbase.client.Result	postAppend(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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)
org.apache.hadoop.hbase.client.CheckAndMutateResult	postCheckAndMutate(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.client.CheckAndMutate checkAndMutate, org.apache.hadoop.hbase.client.CheckAndMutateResult result)
boolean	postCheckAndPut(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends 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<? extends 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<? extends org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, boolean abortRequested)
void	postCloseRegionOperation(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> ctx, org.apache.hadoop.hbase.regionserver.Region.Operation op)
void	postCompact(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c)
void	postPut(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends 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<? extends org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.regionserver.InternalScanner s)
boolean	postScannerFilterRow(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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)
org.apache.hadoop.hbase.client.Result	preAppend(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends 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<? extends org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, org.apache.hadoop.hbase.client.Append append)
void	preBatchMutate(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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)
org.apache.hadoop.hbase.client.CheckAndMutateResult	preCheckAndMutate(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.client.CheckAndMutate checkAndMutate, org.apache.hadoop.hbase.client.CheckAndMutateResult result)
org.apache.hadoop.hbase.client.CheckAndMutateResult	preCheckAndMutateAfterRowLock(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.client.CheckAndMutate checkAndMutate, org.apache.hadoop.hbase.client.CheckAndMutateResult result)
boolean	preCheckAndPut(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends 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<? extends 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<? extends 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<? extends 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<? extends org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, boolean abortRequested)
org.apache.hadoop.hbase.regionserver.InternalScanner	preCompact(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, org.apache.hadoop.hbase.client.Increment increment)
void	preMemStoreCompactionCompactScannerOpen(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends 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<? extends org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c)
void	prePrepareTimeStampForDeleteVersion(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends 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<? extends 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<? extends org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c, org.apache.hadoop.hbase.regionserver.InternalScanner s)
boolean	preScannerNext(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends 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<? extends 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<? extends 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<? extends 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<? extends org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> ctx, org.apache.hadoop.hbase.wal.WALKey key, org.apache.hadoop.hbase.wal.WALEdit edit)
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

getServices, stop

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

getBulkLoadObserver, getEndpointObserver

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

postAppend, postAppendBeforeWAL, postCommitStoreFile, postDelete, postExists, postFlush, postIncrement, postIncrementBeforeWAL, postInstantiateDeleteTracker, postMemStoreCompaction, postMutationBeforeWAL, postPut, preAppend, preCommitStoreFile, preDelete, preExists, preFlush, preIncrement, preMemStoreCompaction, preMemStoreCompactionCompact, prePut

Field Details

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

ctPreCheckAndMutate

final AtomicInteger ctPreCheckAndMutate

ctPreCheckAndMutateAfterRowLock

final AtomicInteger ctPreCheckAndMutateAfterRowLock

ctPostCheckAndMutate

final AtomicInteger ctPostCheckAndMutate

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

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 Details

SimpleRegionObserver

public SimpleRegionObserver()

Method Details

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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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

preCheckAndMutate

public org.apache.hadoop.hbase.client.CheckAndMutateResult preCheckAndMutate(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
 org.apache.hadoop.hbase.client.CheckAndMutate checkAndMutate,
 org.apache.hadoop.hbase.client.CheckAndMutateResult result)
                                                                      throws IOException

Specified by:

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

Throws:

IOException

preCheckAndMutateAfterRowLock

public org.apache.hadoop.hbase.client.CheckAndMutateResult preCheckAndMutateAfterRowLock(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
 org.apache.hadoop.hbase.client.CheckAndMutate checkAndMutate,
 org.apache.hadoop.hbase.client.CheckAndMutateResult result)
                                                                                  throws IOException

Specified by:

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

Throws:

IOException

postCheckAndMutate

public org.apache.hadoop.hbase.client.CheckAndMutateResult postCheckAndMutate(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> c,
 org.apache.hadoop.hbase.client.CheckAndMutate checkAndMutate,
 org.apache.hadoop.hbase.client.CheckAndMutateResult result)
                                                                       throws IOException

Specified by:

postCheckAndMutate 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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

preStoreFileReaderOpen

public org.apache.hadoop.hbase.regionserver.StoreFileReader preStoreFileReaderOpen(org.apache.hadoop.hbase.coprocessor.ObserverContext<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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<? extends 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()

getPreBatchMutate

public int getPreBatchMutate()

hadPostBatchMutate

public boolean hadPostBatchMutate()

getPostBatchMutate

public int getPostBatchMutate()

hadPostBatchMutateIndispensably

public boolean hadPostBatchMutateIndispensably()

getPostBatchMutateIndispensably

public int getPostBatchMutateIndispensably()

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

getPreCheckAndMutate

public int getPreCheckAndMutate()

getPreCheckAndMutateAfterRowLock

public int getPreCheckAndMutateAfterRowLock()

getPostCheckAndMutate

public int getPostCheckAndMutate()

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

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

getCtPreWALAppend

public int getCtPreWALAppend()

wasStoreFileReaderOpenCalled

public boolean wasStoreFileReaderOpenCalled()