com.splicemachine.si.data.hbase.coprocessor

Class SIObserver

java.lang.Object

org.apache.hadoop.hbase.coprocessor.BaseRegionObserver

com.splicemachine.si.data.hbase.coprocessor.SIObserver

All Implemented Interfaces:

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

public class SIObserver
extends org.apache.hadoop.hbase.coprocessor.BaseRegionObserver

An HBase coprocessor that applies SI logic to HBase read/write operations.

Nested Class Summary

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

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

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

org.apache.hadoop.hbase.Coprocessor.State

Field Summary

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

PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION

Constructor Summary

Constructors

Constructor and Description
SIObserver()

Method Summary

Modifier and Type	Method and Description
void	postCompact(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, org.apache.hadoop.hbase.regionserver.Store store, org.apache.hadoop.hbase.regionserver.StoreFile resultFile)
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)
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, java.util.List<org.apache.hadoop.hbase.util.Pair<byte[],java.lang.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.filter.CompareFilter.CompareOp compareOp, org.apache.hadoop.hbase.filter.ByteArrayComparable comparator, org.apache.hadoop.hbase.client.Delete delete, boolean result)
boolean	preCheckAndPut(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, byte[] row, byte[] family, byte[] qualifier, org.apache.hadoop.hbase.filter.CompareFilter.CompareOp compareOp, org.apache.hadoop.hbase.filter.ByteArrayComparable comparator, org.apache.hadoop.hbase.client.Put put, boolean result)
org.apache.hadoop.hbase.regionserver.InternalScanner	preCompact(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, org.apache.hadoop.hbase.regionserver.Store store, org.apache.hadoop.hbase.regionserver.InternalScanner scanner, org.apache.hadoop.hbase.regionserver.ScanType scanType, org.apache.hadoop.hbase.regionserver.compactions.CompactionRequest compactionRequest)
void	preDelete(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, org.apache.hadoop.hbase.client.Delete delete, org.apache.hadoop.hbase.regionserver.wal.WALEdit edit, org.apache.hadoop.hbase.client.Durability writeToWAL)
boolean	preExists(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, org.apache.hadoop.hbase.client.Get get, boolean exists)
org.apache.hadoop.hbase.regionserver.InternalScanner	preFlush(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, org.apache.hadoop.hbase.regionserver.Store store, org.apache.hadoop.hbase.regionserver.InternalScanner scanner)
void	preGetClosestRowBefore(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, byte[] row, byte[] family, org.apache.hadoop.hbase.client.Result result)
void	preGetOp(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, org.apache.hadoop.hbase.client.Get get, java.util.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> e, org.apache.hadoop.hbase.client.Increment increment)
void	prePut(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, org.apache.hadoop.hbase.client.Put put, org.apache.hadoop.hbase.regionserver.wal.WALEdit edit, org.apache.hadoop.hbase.client.Durability writeToWAL)
org.apache.hadoop.hbase.regionserver.RegionScanner	preScannerOpen(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e, org.apache.hadoop.hbase.client.Scan scan, org.apache.hadoop.hbase.regionserver.RegionScanner s)
void	start(org.apache.hadoop.hbase.CoprocessorEnvironment e)
void	stop(org.apache.hadoop.hbase.CoprocessorEnvironment e)

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

postAppend, postBatchMutate, postBatchMutateIndispensably, postBulkLoadHFile, postCheckAndDelete, postCheckAndPut, postClose, postCloseRegionOperation, postCompact, postCompactSelection, postCompactSelection, postCompleteSplit, postDelete, postExists, postFlush, postFlush, postGetClosestRowBefore, postGetOp, postIncrement, postIncrementColumnValue, postInstantiateDeleteTracker, postLogReplay, postMutationBeforeWAL, postOpen, postPut, postRollBackSplit, postScannerClose, postScannerFilterRow, postScannerNext, postScannerOpen, postSplit, postStartRegionOperation, postStoreFileReaderOpen, postWALRestore, postWALRestore, preAppendAfterRowLock, preCheckAndDeleteAfterRowLock, preCheckAndPutAfterRowLock, preClose, preCompact, preCompactScannerOpen, preCompactScannerOpen, preCompactSelection, preCompactSelection, preFlush, preFlushScannerOpen, preIncrementAfterRowLock, preIncrementColumnValue, preOpen, prePrepareTimeStampForDeleteVersion, preRollBackSplit, preScannerClose, preScannerNext, preSplit, preSplit, preSplitAfterPONR, preSplitBeforePONR, preStoreFileReaderOpen, preStoreScannerOpen, preWALRestore, preWALRestore

Methods inherited from class java.lang.Object

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

Constructor Detail

SIObserver

public SIObserver()

Method Detail

start

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

Specified by:

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

Overrides:

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

Throws:

java.io.IOException

stop

public void stop(org.apache.hadoop.hbase.CoprocessorEnvironment e)
          throws java.io.IOException

Specified by:

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

Overrides:

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

Throws:

java.io.IOException

preGetOp

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

Specified by:

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

Overrides:

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

Throws:

java.io.IOException

preScannerOpen

public org.apache.hadoop.hbase.regionserver.RegionScanner preScannerOpen(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e,
                                                                         org.apache.hadoop.hbase.client.Scan scan,
                                                                         org.apache.hadoop.hbase.regionserver.RegionScanner s)
                                                                  throws java.io.IOException

Specified by:

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

Overrides:

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

Throws:

java.io.IOException

postCompact

public void postCompact(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e,
                        org.apache.hadoop.hbase.regionserver.Store store,
                        org.apache.hadoop.hbase.regionserver.StoreFile resultFile)
                 throws java.io.IOException

Specified by:

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

Overrides:

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

Throws:

java.io.IOException

preDelete

public void preDelete(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e,
                      org.apache.hadoop.hbase.client.Delete delete,
                      org.apache.hadoop.hbase.regionserver.wal.WALEdit edit,
                      org.apache.hadoop.hbase.client.Durability writeToWAL)
               throws java.io.IOException

Specified by:

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

Overrides:

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

Throws:

java.io.IOException

preFlush

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

Specified by:

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

Overrides:

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

Throws:

java.io.IOException

preCompact

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

Specified by:

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

Overrides:

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

Throws:

java.io.IOException

prePut

public void prePut(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e,
                   org.apache.hadoop.hbase.client.Put put,
                   org.apache.hadoop.hbase.regionserver.wal.WALEdit edit,
                   org.apache.hadoop.hbase.client.Durability writeToWAL)
            throws java.io.IOException

Specified by:

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

Overrides:

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

Throws:

java.io.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 java.io.IOException

Specified by:

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

Overrides:

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

Throws:

java.io.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.filter.CompareFilter.CompareOp compareOp,
                                 org.apache.hadoop.hbase.filter.ByteArrayComparable comparator,
                                 org.apache.hadoop.hbase.client.Delete delete,
                                 boolean result)
                          throws java.io.IOException

Specified by:

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

Overrides:

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

Throws:

java.io.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.filter.CompareFilter.CompareOp compareOp,
                              org.apache.hadoop.hbase.filter.ByteArrayComparable comparator,
                              org.apache.hadoop.hbase.client.Put put,
                              boolean result)
                       throws java.io.IOException

Specified by:

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

Overrides:

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

Throws:

java.io.IOException

preExists

public boolean preExists(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e,
                         org.apache.hadoop.hbase.client.Get get,
                         boolean exists)
                  throws java.io.IOException

Specified by:

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

Overrides:

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

Throws:

java.io.IOException

preIncrement

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

Specified by:

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

Overrides:

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

Throws:

java.io.IOException

preGetClosestRowBefore

public void preGetClosestRowBefore(org.apache.hadoop.hbase.coprocessor.ObserverContext<org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment> e,
                                   byte[] row,
                                   byte[] family,
                                   org.apache.hadoop.hbase.client.Result result)
                            throws java.io.IOException

Specified by:

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

Overrides:

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

Throws:

java.io.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 java.io.IOException

Specified by:

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

Overrides:

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

Throws:

java.io.IOException

preBulkLoadHFile

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

Specified by:

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

Overrides:

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

Throws:

java.io.IOException