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
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) final AtomicInteger
     
    (package private) Map<String,byte[]>
     
    (package private) static final String
     
    (package private) final AtomicBoolean
     
    (package private) static final byte[]
     

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

    PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION
  • Constructor Summary

    Constructors
    Constructor
    Description
     
  • Method Summary

    Modifier and Type
    Method
    Description
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    int
     
    Optional<org.apache.hadoop.hbase.coprocessor.RegionObserver>
     
    boolean
     
    boolean
     
    boolean
     
    boolean
     
    boolean
     
    boolean
     
    boolean
     
    boolean
     
    boolean
     
    boolean
     
    boolean
     
    boolean
     
    boolean
     
    boolean
     
    boolean
     
    boolean
     
    boolean
     
    boolean
     
    boolean
     
    boolean
     
    boolean
     
    boolean
     
    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)
     
    org.apache.hadoop.hbase.client.CheckAndMutateResult
    postCheckAndMutate(org.apache.hadoop.hbase.coprocessor.ObserverContext<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<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)
     
    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)
     
    org.apache.hadoop.hbase.client.CheckAndMutateResult
    preCheckAndMutate(org.apache.hadoop.hbase.coprocessor.ObserverContext<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<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<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)
     
    private void
    setScanOptions(org.apache.hadoop.hbase.regionserver.ScanOptions options)
     
    void
     
    void
    start(org.apache.hadoop.hbase.CoprocessorEnvironment e)
     
    boolean
     
    boolean
     
    boolean
     
    boolean
     
    boolean
     
    boolean
     
    boolean
     
    boolean
     
    boolean
     

    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

  • Constructor Details

  • 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<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
    • preCheckAndMutate

      public org.apache.hadoop.hbase.client.CheckAndMutateResult preCheckAndMutate(org.apache.hadoop.hbase.coprocessor.ObserverContext<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<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<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<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
    • 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()
    • getPreBatchMutate

      public int getPreBatchMutate()
    • hadPostBatchMutate

      public boolean hadPostBatchMutate()
    • getPostBatchMutate

      public int getPostBatchMutate()
    • hadPostBatchMutateIndispensably

    • getPostBatchMutateIndispensably

    • hadPostStartRegionOperation

      public boolean hadPostStartRegionOperation()
    • hadPostCloseRegionOperation

      public boolean hadPostCloseRegionOperation()
    • hadDelete

      public boolean hadDelete()
    • getCtPostStartRegionOperation

    • getCtPostCloseRegionOperation

    • getPreCheckAndPut

      public int getPreCheckAndPut()
    • getPreCheckAndPutWithFilter

    • getPreCheckAndPutAfterRowLock

    • getPreCheckAndPutWithFilterAfterRowLock

    • getPostCheckAndPut

      public int getPostCheckAndPut()
    • getPostCheckAndPutWithFilter

    • getPreCheckAndDelete

      public int getPreCheckAndDelete()
    • getPreCheckAndDeleteWithFilter

    • getPreCheckAndDeleteAfterRowLock

    • getPreCheckAndDeleteWithFilterAfterRowLock

    • getPostCheckAndDelete

      public int getPostCheckAndDelete()
    • getPostCheckAndDeleteWithFilter

    • getPreCheckAndMutate

      public int getPreCheckAndMutate()
    • 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()