Uses of Interface
org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment

Packages that use RegionCoprocessorEnvironment

Package	Description
org.apache.hadoop.hbase.constraint	Restrict the domain of a data attribute, often times to fulfill business rules/requirements.
org.apache.hadoop.hbase.coprocessor	Table of Contents
org.apache.hadoop.hbase.coprocessor.example
org.apache.hadoop.hbase.security.access
org.apache.hadoop.hbase.security.visibility
org.apache.hadoop.hbase.tool

Uses of RegionCoprocessorEnvironment in org.apache.hadoop.hbase.constraint

Method parameters in org.apache.hadoop.hbase.constraint with type arguments of type RegionCoprocessorEnvironment

Modifier and Type	Method and Description
void	ConstraintProcessor.prePut(ObserverContext<RegionCoprocessorEnvironment> e, Put put, WALEdit edit, Durability durability)

Uses of RegionCoprocessorEnvironment in org.apache.hadoop.hbase.coprocessor

Method parameters in org.apache.hadoop.hbase.coprocessor with type arguments of type RegionCoprocessorEnvironment

Modifier and Type	Method and Description
Result	RegionObserver.postAppend(ObserverContext<RegionCoprocessorEnvironment> c, Append append, Result result) Called after Append
Result	BaseRegionObserver.postAppend(ObserverContext<RegionCoprocessorEnvironment> e, Append append, Result result)
void	RegionObserver.postBatchMutate(ObserverContext<RegionCoprocessorEnvironment> c, MiniBatchOperationInProgress<Mutation> miniBatchOp) This will be called after applying a batch of Mutations on a region.
void	BaseRegionObserver.postBatchMutate(ObserverContext<RegionCoprocessorEnvironment> c, MiniBatchOperationInProgress<Mutation> miniBatchOp)
void	RegionObserver.postBatchMutateIndispensably(ObserverContext<RegionCoprocessorEnvironment> ctx, MiniBatchOperationInProgress<Mutation> miniBatchOp, boolean success) Called after the completion of batch put/delete and will be called even if the batch operation fails
void	BaseRegionObserver.postBatchMutateIndispensably(ObserverContext<RegionCoprocessorEnvironment> ctx, MiniBatchOperationInProgress<Mutation> miniBatchOp, boolean success)
boolean	RegionObserver.postBulkLoadHFile(ObserverContext<RegionCoprocessorEnvironment> ctx, List<Pair<byte[],String>> familyPaths, boolean hasLoaded) Called after bulkLoadHFile.
boolean	BaseRegionObserver.postBulkLoadHFile(ObserverContext<RegionCoprocessorEnvironment> ctx, List<Pair<byte[],String>> familyPaths, boolean hasLoaded)
boolean	RegionObserver.postCheckAndDelete(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareFilter.CompareOp compareOp, ByteArrayComparable comparator, Delete delete, boolean result) Called after checkAndDelete
boolean	BaseRegionObserver.postCheckAndDelete(ObserverContext<RegionCoprocessorEnvironment> e, byte[] row, byte[] family, byte[] qualifier, CompareFilter.CompareOp compareOp, ByteArrayComparable comparator, Delete delete, boolean result)
boolean	RegionObserver.postCheckAndPut(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareFilter.CompareOp compareOp, ByteArrayComparable comparator, Put put, boolean result) Called after checkAndPut
boolean	BaseRegionObserver.postCheckAndPut(ObserverContext<RegionCoprocessorEnvironment> e, byte[] row, byte[] family, byte[] qualifier, CompareFilter.CompareOp compareOp, ByteArrayComparable comparator, Put put, boolean result)
void	RegionObserver.postClose(ObserverContext<RegionCoprocessorEnvironment> c, boolean abortRequested) Called after the region is reported as closed to the master.
void	BaseRegionObserver.postClose(ObserverContext<RegionCoprocessorEnvironment> e, boolean abortRequested)
void	RegionObserver.postCloseRegionOperation(ObserverContext<RegionCoprocessorEnvironment> ctx, Region.Operation operation) Called after releasing read lock in Region.closeRegionOperation().
void	BaseRegionObserver.postCloseRegionOperation(ObserverContext<RegionCoprocessorEnvironment> ctx, Region.Operation op)
void	RegionObserver.postCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store, StoreFile resultFile) Deprecated. Use RegionObserver.postCompact(ObserverContext, Store, StoreFile, CompactionRequest) instead
void	BaseRegionObserver.postCompact(ObserverContext<RegionCoprocessorEnvironment> e, Store store, StoreFile resultFile)
void	RegionObserver.postCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store, StoreFile resultFile, CompactionRequest request) Called after compaction has completed and the new store file has been moved in to place.
void	BaseRegionObserver.postCompact(ObserverContext<RegionCoprocessorEnvironment> e, Store store, StoreFile resultFile, CompactionRequest request)
void	RegionObserver.postCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c, Store store, com.google.common.collect.ImmutableList<StoreFile> selected) Deprecated. use RegionObserver.postCompactSelection(ObserverContext, Store, ImmutableList, CompactionRequest) instead.
void	BaseRegionObserver.postCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c, Store store, com.google.common.collect.ImmutableList<StoreFile> selected)
void	RegionObserver.postCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c, Store store, com.google.common.collect.ImmutableList<StoreFile> selected, CompactionRequest request) Called after the StoreFiles to compact have been selected from the available candidates.
void	BaseRegionObserver.postCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c, Store store, com.google.common.collect.ImmutableList<StoreFile> selected, CompactionRequest request)
void	RegionObserver.postCompleteSplit(ObserverContext<RegionCoprocessorEnvironment> ctx) Called after any split request is processed.
void	BaseRegionObserver.postCompleteSplit(ObserverContext<RegionCoprocessorEnvironment> ctx)
void	RegionObserver.postDelete(ObserverContext<RegionCoprocessorEnvironment> c, Delete delete, WALEdit edit, Durability durability) Called after the client deletes a value.
void	BaseRegionObserver.postDelete(ObserverContext<RegionCoprocessorEnvironment> e, Delete delete, WALEdit edit, Durability durability)
void	EndpointObserver.postEndpointInvocation(ObserverContext<RegionCoprocessorEnvironment> ctx, com.google.protobuf.Service service, String methodName, com.google.protobuf.Message request, com.google.protobuf.Message.Builder responseBuilder) Called after an Endpoint service method is invoked.
boolean	RegionObserver.postExists(ObserverContext<RegionCoprocessorEnvironment> c, Get get, boolean exists) Called after the client tests for existence using a Get.
boolean	BaseRegionObserver.postExists(ObserverContext<RegionCoprocessorEnvironment> e, Get get, boolean exists)
void	RegionObserver.postFlush(ObserverContext<RegionCoprocessorEnvironment> c) Deprecated. use RegionObserver.preFlush(ObserverContext, Store, InternalScanner) instead.
void	BaseRegionObserver.postFlush(ObserverContext<RegionCoprocessorEnvironment> e)
void	RegionObserver.postFlush(ObserverContext<RegionCoprocessorEnvironment> c, Store store, StoreFile resultFile) Called after a Store's memstore is flushed to disk.
void	BaseRegionObserver.postFlush(ObserverContext<RegionCoprocessorEnvironment> e, Store store, StoreFile resultFile)
void	RegionObserver.postGetClosestRowBefore(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, Result result) Called after a client makes a GetClosestRowBefore request.
void	BaseRegionObserver.postGetClosestRowBefore(ObserverContext<RegionCoprocessorEnvironment> e, byte[] row, byte[] family, Result result)
void	RegionObserver.postGetOp(ObserverContext<RegionCoprocessorEnvironment> c, Get get, List<Cell> result) Called after the client performs a Get
void	BaseRegionObserver.postGetOp(ObserverContext<RegionCoprocessorEnvironment> e, Get get, List<Cell> results)
Result	RegionObserver.postIncrement(ObserverContext<RegionCoprocessorEnvironment> c, Increment increment, Result result) Called after increment
Result	BaseRegionObserver.postIncrement(ObserverContext<RegionCoprocessorEnvironment> e, Increment increment, Result result)
long	RegionObserver.postIncrementColumnValue(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, long amount, boolean writeToWAL, long result) Deprecated. This hook is no longer called by the RegionServer
long	BaseRegionObserver.postIncrementColumnValue(ObserverContext<RegionCoprocessorEnvironment> e, byte[] row, byte[] family, byte[] qualifier, long amount, boolean writeToWAL, long result)
DeleteTracker	RegionObserver.postInstantiateDeleteTracker(ObserverContext<RegionCoprocessorEnvironment> ctx, DeleteTracker delTracker) Called after the ScanQueryMatcher creates ScanDeleteTracker.
DeleteTracker	BaseRegionObserver.postInstantiateDeleteTracker(ObserverContext<RegionCoprocessorEnvironment> ctx, DeleteTracker delTracker)
void	RegionObserver.postLogReplay(ObserverContext<RegionCoprocessorEnvironment> c) Called after the log replay on the region is over.
void	BaseRegionObserver.postLogReplay(ObserverContext<RegionCoprocessorEnvironment> e)
Cell	RegionObserver.postMutationBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, RegionObserver.MutationType opType, Mutation mutation, Cell oldCell, Cell newCell) Called after a new cell has been created during an increment operation, but before it is committed to the WAL or memstore.
Cell	BaseRegionObserver.postMutationBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, RegionObserver.MutationType opType, Mutation mutation, Cell oldCell, Cell newCell)
void	RegionObserver.postOpen(ObserverContext<RegionCoprocessorEnvironment> c) Called after the region is reported as open to the master.
void	BaseRegionObserver.postOpen(ObserverContext<RegionCoprocessorEnvironment> e)
void	RegionObserver.postPut(ObserverContext<RegionCoprocessorEnvironment> c, Put put, WALEdit edit, Durability durability) Called after the client stores a value.
void	BaseRegionObserver.postPut(ObserverContext<RegionCoprocessorEnvironment> e, Put put, WALEdit edit, Durability durability)
void	RegionObserver.postRollBackSplit(ObserverContext<RegionCoprocessorEnvironment> ctx) This will be called after the roll back of the split region is completed
void	BaseRegionObserver.postRollBackSplit(ObserverContext<RegionCoprocessorEnvironment> ctx)
void	RegionObserver.postScannerClose(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s) Called after the client closes a scanner.
void	BaseRegionObserver.postScannerClose(ObserverContext<RegionCoprocessorEnvironment> e, InternalScanner s)
boolean	RegionObserver.postScannerFilterRow(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s, byte[] currentRow, int offset, short length, boolean hasMore) This will be called by the scan flow when the current scanned row is being filtered out by the filter.
boolean	BaseRegionObserver.postScannerFilterRow(ObserverContext<RegionCoprocessorEnvironment> e, InternalScanner s, byte[] currentRow, int offset, short length, boolean hasMore)
boolean	RegionObserver.postScannerNext(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s, List<Result> result, int limit, boolean hasNext) Called after the client asks for the next row on a scanner.
boolean	BaseRegionObserver.postScannerNext(ObserverContext<RegionCoprocessorEnvironment> e, InternalScanner s, List<Result> results, int limit, boolean hasMore)
RegionScanner	RegionObserver.postScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Scan scan, RegionScanner s) Called after the client opens a new scanner.
RegionScanner	BaseRegionObserver.postScannerOpen(ObserverContext<RegionCoprocessorEnvironment> e, Scan scan, RegionScanner s)
void	RegionObserver.postSplit(ObserverContext<RegionCoprocessorEnvironment> c, Region l, Region r) Deprecated. Use postCompleteSplit() instead
void	BaseRegionObserver.postSplit(ObserverContext<RegionCoprocessorEnvironment> e, Region l, Region r)
void	RegionObserver.postStartRegionOperation(ObserverContext<RegionCoprocessorEnvironment> ctx, Region.Operation operation) This will be called for region operations where read lock is acquired in Region.startRegionOperation().
void	BaseRegionObserver.postStartRegionOperation(ObserverContext<RegionCoprocessorEnvironment> ctx, Region.Operation op)
StoreFile.Reader	RegionObserver.postStoreFileReaderOpen(ObserverContext<RegionCoprocessorEnvironment> ctx, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path p, FSDataInputStreamWrapper in, long size, CacheConfig cacheConf, Reference r, StoreFile.Reader reader) Called after the creation of Reader for a store file.
StoreFile.Reader	BaseRegionObserver.postStoreFileReaderOpen(ObserverContext<RegionCoprocessorEnvironment> ctx, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path p, FSDataInputStreamWrapper in, long size, CacheConfig cacheConf, Reference r, StoreFile.Reader reader)
void	RegionObserver.postWALRestore(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, HRegionInfo info, WALKey logKey, WALEdit logEdit) Called after a WALEdit replayed for this region.
void	BaseRegionObserver.postWALRestore(ObserverContext<? extends RegionCoprocessorEnvironment> env, HRegionInfo info, WALKey logKey, WALEdit logEdit) Implementers should override this version of the method and leave the deprecated one as-is.
void	RegionObserver.postWALRestore(ObserverContext<RegionCoprocessorEnvironment> ctx, HRegionInfo info, HLogKey logKey, WALEdit logEdit) Deprecated. use RegionObserver.postWALRestore(ObserverContext, HRegionInfo, WALKey, WALEdit)
void	BaseRegionObserver.postWALRestore(ObserverContext<RegionCoprocessorEnvironment> env, HRegionInfo info, HLogKey logKey, WALEdit logEdit)
Result	RegionObserver.preAppend(ObserverContext<RegionCoprocessorEnvironment> c, Append append) Called before Append.
Result	BaseRegionObserver.preAppend(ObserverContext<RegionCoprocessorEnvironment> e, Append append)
Result	RegionObserver.preAppendAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c, Append append) Called before Append but after acquiring rowlock.
Result	BaseRegionObserver.preAppendAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> e, Append append)
void	RegionObserver.preBatchMutate(ObserverContext<RegionCoprocessorEnvironment> c, MiniBatchOperationInProgress<Mutation> miniBatchOp) This will be called for every batch mutation operation happening at the server.
void	BaseRegionObserver.preBatchMutate(ObserverContext<RegionCoprocessorEnvironment> c, MiniBatchOperationInProgress<Mutation> miniBatchOp)
void	RegionObserver.preBulkLoadHFile(ObserverContext<RegionCoprocessorEnvironment> ctx, List<Pair<byte[],String>> familyPaths) Called before bulkLoadHFile.
void	BaseRegionObserver.preBulkLoadHFile(ObserverContext<RegionCoprocessorEnvironment> ctx, List<Pair<byte[],String>> familyPaths)
boolean	RegionObserver.preCheckAndDelete(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareFilter.CompareOp compareOp, ByteArrayComparable comparator, Delete delete, boolean result) Called before checkAndDelete.
boolean	BaseRegionObserver.preCheckAndDelete(ObserverContext<RegionCoprocessorEnvironment> e, byte[] row, byte[] family, byte[] qualifier, CompareFilter.CompareOp compareOp, ByteArrayComparable comparator, Delete delete, boolean result)
boolean	RegionObserver.preCheckAndDeleteAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareFilter.CompareOp compareOp, ByteArrayComparable comparator, Delete delete, boolean result) Called before checkAndDelete but after acquiring rowock.
boolean	BaseRegionObserver.preCheckAndDeleteAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> e, byte[] row, byte[] family, byte[] qualifier, CompareFilter.CompareOp compareOp, ByteArrayComparable comparator, Delete delete, boolean result)
boolean	RegionObserver.preCheckAndPut(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareFilter.CompareOp compareOp, ByteArrayComparable comparator, Put put, boolean result) Called before checkAndPut.
boolean	BaseRegionObserver.preCheckAndPut(ObserverContext<RegionCoprocessorEnvironment> e, byte[] row, byte[] family, byte[] qualifier, CompareFilter.CompareOp compareOp, ByteArrayComparable comparator, Put put, boolean result)
boolean	RegionObserver.preCheckAndPutAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareFilter.CompareOp compareOp, ByteArrayComparable comparator, Put put, boolean result) Called before checkAndPut but after acquiring rowlock.
boolean	BaseRegionObserver.preCheckAndPutAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> e, byte[] row, byte[] family, byte[] qualifier, CompareFilter.CompareOp compareOp, ByteArrayComparable comparator, Put put, boolean result)
void	BulkLoadObserver.preCleanupBulkLoad(ObserverContext<RegionCoprocessorEnvironment> ctx, SecureBulkLoadProtos.CleanupBulkLoadRequest request) Called as part of SecureBulkLoadEndpoint.cleanupBulkLoad() RPC call.
void	RegionObserver.preClose(ObserverContext<RegionCoprocessorEnvironment> c, boolean abortRequested) Called before the region is reported as closed to the master.
void	BaseRegionObserver.preClose(ObserverContext<RegionCoprocessorEnvironment> c, boolean abortRequested)
InternalScanner	RegionObserver.preCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType) Deprecated. use RegionObserver.preCompact(ObserverContext, Store, InternalScanner, ScanType, CompactionRequest) instead
InternalScanner	BaseRegionObserver.preCompact(ObserverContext<RegionCoprocessorEnvironment> e, Store store, InternalScanner scanner, ScanType scanType)
InternalScanner	RegionObserver.preCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, CompactionRequest request) Called prior to writing the StoreFiles selected for compaction into a new StoreFile.
InternalScanner	BaseRegionObserver.preCompact(ObserverContext<RegionCoprocessorEnvironment> e, Store store, InternalScanner scanner, ScanType scanType, CompactionRequest request)
InternalScanner	RegionObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store, List<? extends KeyValueScanner> scanners, ScanType scanType, long earliestPutTs, InternalScanner s) Deprecated. Use RegionObserver.preCompactScannerOpen(ObserverContext, Store, List, ScanType, long, InternalScanner, CompactionRequest) instead.
InternalScanner	BaseRegionObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store, List<? extends KeyValueScanner> scanners, ScanType scanType, long earliestPutTs, InternalScanner s)
InternalScanner	RegionObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store, List<? extends KeyValueScanner> scanners, ScanType scanType, long earliestPutTs, InternalScanner s, CompactionRequest request) Called prior to writing the StoreFiles selected for compaction into a new StoreFile and prior to creating the scanner used to read the input files.
InternalScanner	BaseRegionObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store, List<? extends KeyValueScanner> scanners, ScanType scanType, long earliestPutTs, InternalScanner s, CompactionRequest request)
void	RegionObserver.preCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c, Store store, List<StoreFile> candidates) Deprecated. Use RegionObserver.preCompactSelection(ObserverContext, Store, List, CompactionRequest) instead
void	BaseRegionObserver.preCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c, Store store, List<StoreFile> candidates)
void	RegionObserver.preCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c, Store store, List<StoreFile> candidates, CompactionRequest request) Called prior to selecting the StoreFiles to compact from the list of available candidates.
void	BaseRegionObserver.preCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c, Store store, List<StoreFile> candidates, CompactionRequest request)
void	RegionObserver.preDelete(ObserverContext<RegionCoprocessorEnvironment> c, Delete delete, WALEdit edit, Durability durability) Called before the client deletes a value.
void	BaseRegionObserver.preDelete(ObserverContext<RegionCoprocessorEnvironment> e, Delete delete, WALEdit edit, Durability durability)
com.google.protobuf.Message	EndpointObserver.preEndpointInvocation(ObserverContext<RegionCoprocessorEnvironment> ctx, com.google.protobuf.Service service, String methodName, com.google.protobuf.Message request) Called before an Endpoint service method is invoked.
boolean	RegionObserver.preExists(ObserverContext<RegionCoprocessorEnvironment> c, Get get, boolean exists) Called before the client tests for existence using a Get.
boolean	BaseRegionObserver.preExists(ObserverContext<RegionCoprocessorEnvironment> e, Get get, boolean exists)
void	RegionObserver.preFlush(ObserverContext<RegionCoprocessorEnvironment> c) Deprecated. use RegionObserver.preFlush(ObserverContext, Store, InternalScanner) instead
void	BaseRegionObserver.preFlush(ObserverContext<RegionCoprocessorEnvironment> e)
InternalScanner	RegionObserver.preFlush(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner) Called before a Store's memstore is flushed to disk.
InternalScanner	BaseRegionObserver.preFlush(ObserverContext<RegionCoprocessorEnvironment> e, Store store, InternalScanner scanner)
InternalScanner	RegionObserver.preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store, KeyValueScanner memstoreScanner, InternalScanner s) Called before a memstore is flushed to disk and prior to creating the scanner to read from the memstore.
InternalScanner	BaseRegionObserver.preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store, KeyValueScanner memstoreScanner, InternalScanner s)
void	RegionObserver.preGetClosestRowBefore(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, Result result) Called before a client makes a GetClosestRowBefore request.
void	BaseRegionObserver.preGetClosestRowBefore(ObserverContext<RegionCoprocessorEnvironment> e, byte[] row, byte[] family, Result result)
void	RegionObserver.preGetOp(ObserverContext<RegionCoprocessorEnvironment> c, Get get, List<Cell> result) Called before the client performs a Get
void	BaseRegionObserver.preGetOp(ObserverContext<RegionCoprocessorEnvironment> e, Get get, List<Cell> results)
Result	RegionObserver.preIncrement(ObserverContext<RegionCoprocessorEnvironment> c, Increment increment) Called before Increment.
Result	BaseRegionObserver.preIncrement(ObserverContext<RegionCoprocessorEnvironment> e, Increment increment)
Result	RegionObserver.preIncrementAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c, Increment increment) Called before Increment but after acquiring rowlock.
Result	BaseRegionObserver.preIncrementAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> e, Increment increment)
long	RegionObserver.preIncrementColumnValue(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, long amount, boolean writeToWAL) Deprecated. This hook is no longer called by the RegionServer
long	BaseRegionObserver.preIncrementColumnValue(ObserverContext<RegionCoprocessorEnvironment> e, byte[] row, byte[] family, byte[] qualifier, long amount, boolean writeToWAL)
void	RegionObserver.preOpen(ObserverContext<RegionCoprocessorEnvironment> c) Called before the region is reported as open to the master.
void	BaseRegionObserver.preOpen(ObserverContext<RegionCoprocessorEnvironment> e)
void	BulkLoadObserver.prePrepareBulkLoad(ObserverContext<RegionCoprocessorEnvironment> ctx, SecureBulkLoadProtos.PrepareBulkLoadRequest request) Called as part of SecureBulkLoadEndpoint.prepareBulkLoad() RPC call.
void	RegionObserver.prePrepareTimeStampForDeleteVersion(ObserverContext<RegionCoprocessorEnvironment> c, Mutation mutation, Cell cell, byte[] byteNow, Get get) Called before the server updates the timestamp for version delete with latest timestamp.
void	BaseRegionObserver.prePrepareTimeStampForDeleteVersion(ObserverContext<RegionCoprocessorEnvironment> e, Mutation delete, Cell cell, byte[] byteNow, Get get)
void	RegionObserver.prePut(ObserverContext<RegionCoprocessorEnvironment> c, Put put, WALEdit edit, Durability durability) Called before the client stores a value.
void	BaseRegionObserver.prePut(ObserverContext<RegionCoprocessorEnvironment> e, Put put, WALEdit edit, Durability durability)
void	RegionObserver.preRollBackSplit(ObserverContext<RegionCoprocessorEnvironment> ctx) This will be called before the roll back of the split region is completed
void	BaseRegionObserver.preRollBackSplit(ObserverContext<RegionCoprocessorEnvironment> ctx)
void	RegionObserver.preScannerClose(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s) Called before the client closes a scanner.
void	BaseRegionObserver.preScannerClose(ObserverContext<RegionCoprocessorEnvironment> e, InternalScanner s)
boolean	RegionObserver.preScannerNext(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s, List<Result> result, int limit, boolean hasNext) Called before the client asks for the next row on a scanner.
boolean	BaseRegionObserver.preScannerNext(ObserverContext<RegionCoprocessorEnvironment> e, InternalScanner s, List<Result> results, int limit, boolean hasMore)
RegionScanner	RegionObserver.preScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Scan scan, RegionScanner s) Called before the client opens a new scanner.
RegionScanner	BaseRegionObserver.preScannerOpen(ObserverContext<RegionCoprocessorEnvironment> e, Scan scan, RegionScanner s)
void	RegionObserver.preSplit(ObserverContext<RegionCoprocessorEnvironment> c) Deprecated. Use preSplit( final ObserverContext c, byte[] splitRow)
void	BaseRegionObserver.preSplit(ObserverContext<RegionCoprocessorEnvironment> e)
void	RegionObserver.preSplit(ObserverContext<RegionCoprocessorEnvironment> c, byte[] splitRow) Called before the region is split.
void	BaseRegionObserver.preSplit(ObserverContext<RegionCoprocessorEnvironment> c, byte[] splitRow)
void	RegionObserver.preSplitAfterPONR(ObserverContext<RegionCoprocessorEnvironment> ctx) This will be called after PONR step as part of split transaction Calling ObserverContext.bypass() has no effect in this hook.
void	BaseRegionObserver.preSplitAfterPONR(ObserverContext<RegionCoprocessorEnvironment> ctx)
void	RegionObserver.preSplitBeforePONR(ObserverContext<RegionCoprocessorEnvironment> ctx, byte[] splitKey, List<Mutation> metaEntries) This will be called before PONR step as part of split transaction.
void	BaseRegionObserver.preSplitBeforePONR(ObserverContext<RegionCoprocessorEnvironment> ctx, byte[] splitKey, List<Mutation> metaEntries)
StoreFile.Reader	RegionObserver.preStoreFileReaderOpen(ObserverContext<RegionCoprocessorEnvironment> ctx, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path p, FSDataInputStreamWrapper in, long size, CacheConfig cacheConf, Reference r, StoreFile.Reader reader) Called before creation of Reader for a store file.
StoreFile.Reader	BaseRegionObserver.preStoreFileReaderOpen(ObserverContext<RegionCoprocessorEnvironment> ctx, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path p, FSDataInputStreamWrapper in, long size, CacheConfig cacheConf, Reference r, StoreFile.Reader reader)
KeyValueScanner	RegionObserver.preStoreScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store, Scan scan, NavigableSet<byte[]> targetCols, KeyValueScanner s) Called before a store opens a new scanner.
KeyValueScanner	BaseRegionObserver.preStoreScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store, Scan scan, NavigableSet<byte[]> targetCols, KeyValueScanner s)
void	RegionObserver.preWALRestore(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, HRegionInfo info, WALKey logKey, WALEdit logEdit) Called before a WALEdit replayed for this region.
void	BaseRegionObserver.preWALRestore(ObserverContext<? extends RegionCoprocessorEnvironment> env, HRegionInfo info, WALKey logKey, WALEdit logEdit) Implementers should override this version of the method and leave the deprecated one as-is.
void	RegionObserver.preWALRestore(ObserverContext<RegionCoprocessorEnvironment> ctx, HRegionInfo info, HLogKey logKey, WALEdit logEdit) Deprecated. use RegionObserver.preWALRestore(ObserverContext, HRegionInfo, WALKey, WALEdit)
void	BaseRegionObserver.preWALRestore(ObserverContext<RegionCoprocessorEnvironment> env, HRegionInfo info, HLogKey logKey, WALEdit logEdit)

Uses of RegionCoprocessorEnvironment in org.apache.hadoop.hbase.coprocessor.example

Methods in org.apache.hadoop.hbase.coprocessor.example with parameters of type RegionCoprocessorEnvironment

Modifier and Type	Method and Description
protected ScanInfo	ZooKeeperScanPolicyObserver.getScanInfo(Store store, RegionCoprocessorEnvironment e)

Method parameters in org.apache.hadoop.hbase.coprocessor.example with type arguments of type RegionCoprocessorEnvironment

Modifier and Type	Method and Description
InternalScanner	ZooKeeperScanPolicyObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store, List<? extends KeyValueScanner> scanners, ScanType scanType, long earliestPutTs, InternalScanner s)
InternalScanner	ZooKeeperScanPolicyObserver.preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store, KeyValueScanner memstoreScanner, InternalScanner s)
KeyValueScanner	ZooKeeperScanPolicyObserver.preStoreScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store, Scan scan, NavigableSet<byte[]> targetCols, KeyValueScanner s)

Uses of RegionCoprocessorEnvironment in org.apache.hadoop.hbase.security.access

Method parameters in org.apache.hadoop.hbase.security.access with type arguments of type RegionCoprocessorEnvironment

Modifier and Type	Method and Description
void	AccessController.postDelete(ObserverContext<RegionCoprocessorEnvironment> c, Delete delete, WALEdit edit, Durability durability)
void	AccessController.postEndpointInvocation(ObserverContext<RegionCoprocessorEnvironment> ctx, com.google.protobuf.Service service, String methodName, com.google.protobuf.Message request, com.google.protobuf.Message.Builder responseBuilder)
void	AccessController.postLogReplay(ObserverContext<RegionCoprocessorEnvironment> c)
Cell	AccessController.postMutationBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, RegionObserver.MutationType opType, Mutation mutation, Cell oldCell, Cell newCell)
void	AccessController.postOpen(ObserverContext<RegionCoprocessorEnvironment> c)
void	AccessController.postPut(ObserverContext<RegionCoprocessorEnvironment> c, Put put, WALEdit edit, Durability durability)
void	AccessController.postScannerClose(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s)
RegionScanner	AccessController.postScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Scan scan, RegionScanner s)
Result	AccessController.preAppend(ObserverContext<RegionCoprocessorEnvironment> c, Append append)
Result	AccessController.preAppendAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c, Append append)
void	AccessController.preBatchMutate(ObserverContext<RegionCoprocessorEnvironment> c, MiniBatchOperationInProgress<Mutation> miniBatchOp)
void	AccessController.preBulkLoadHFile(ObserverContext<RegionCoprocessorEnvironment> ctx, List<Pair<byte[],String>> familyPaths) Verifies user has CREATE privileges on the Column Families involved in the bulkLoadHFile request.
boolean	AccessController.preCheckAndDelete(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareFilter.CompareOp compareOp, ByteArrayComparable comparator, Delete delete, boolean result)
boolean	AccessController.preCheckAndDeleteAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareFilter.CompareOp compareOp, ByteArrayComparable comparator, Delete delete, boolean result)
boolean	AccessController.preCheckAndPut(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareFilter.CompareOp compareOp, ByteArrayComparable comparator, Put put, boolean result)
boolean	AccessController.preCheckAndPutAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareFilter.CompareOp compareOp, ByteArrayComparable comparator, Put put, boolean result)
void	AccessController.preCleanupBulkLoad(ObserverContext<RegionCoprocessorEnvironment> ctx, SecureBulkLoadProtos.CleanupBulkLoadRequest request) Authorization security check for SecureBulkLoadProtocol.cleanupBulkLoad()
void	AccessController.preClose(ObserverContext<RegionCoprocessorEnvironment> e, boolean abortRequested)
InternalScanner	AccessController.preCompact(ObserverContext<RegionCoprocessorEnvironment> e, Store store, InternalScanner scanner, ScanType scanType)
void	AccessController.preDelete(ObserverContext<RegionCoprocessorEnvironment> c, Delete delete, WALEdit edit, Durability durability)
com.google.protobuf.Message	AccessController.preEndpointInvocation(ObserverContext<RegionCoprocessorEnvironment> ctx, com.google.protobuf.Service service, String methodName, com.google.protobuf.Message request)
boolean	AccessController.preExists(ObserverContext<RegionCoprocessorEnvironment> c, Get get, boolean exists)
void	AccessController.preFlush(ObserverContext<RegionCoprocessorEnvironment> e)
void	AccessController.preGetClosestRowBefore(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, Result result)
void	AccessController.preGetOp(ObserverContext<RegionCoprocessorEnvironment> c, Get get, List<Cell> result)
Result	AccessController.preIncrement(ObserverContext<RegionCoprocessorEnvironment> c, Increment increment)
Result	AccessController.preIncrementAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c, Increment increment)
long	AccessController.preIncrementColumnValue(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, long amount, boolean writeToWAL)
void	AccessController.preOpen(ObserverContext<RegionCoprocessorEnvironment> e)
void	AccessController.prePrepareBulkLoad(ObserverContext<RegionCoprocessorEnvironment> ctx, SecureBulkLoadProtos.PrepareBulkLoadRequest request) Authorization check for SecureBulkLoadProtocol.prepareBulkLoad()
void	AccessController.prePut(ObserverContext<RegionCoprocessorEnvironment> c, Put put, WALEdit edit, Durability durability)
void	AccessController.preScannerClose(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s)
boolean	AccessController.preScannerNext(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s, List<Result> result, int limit, boolean hasNext)
RegionScanner	AccessController.preScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Scan scan, RegionScanner s)
void	AccessController.preSplit(ObserverContext<RegionCoprocessorEnvironment> e)
void	AccessController.preSplit(ObserverContext<RegionCoprocessorEnvironment> e, byte[] splitRow)

Uses of RegionCoprocessorEnvironment in org.apache.hadoop.hbase.security.visibility

Methods in org.apache.hadoop.hbase.security.visibility with parameters of type RegionCoprocessorEnvironment

Modifier and Type	Method and Description
void	VisibilityLabelService.init(RegionCoprocessorEnvironment e) System calls this after opening of regions.
void	DefaultVisibilityLabelServiceImpl.init(RegionCoprocessorEnvironment e)

Method parameters in org.apache.hadoop.hbase.security.visibility with type arguments of type RegionCoprocessorEnvironment

Modifier and Type	Method and Description
DeleteTracker	VisibilityController.postInstantiateDeleteTracker(ObserverContext<RegionCoprocessorEnvironment> ctx, DeleteTracker delTracker)
void	VisibilityController.postLogReplay(ObserverContext<RegionCoprocessorEnvironment> e)
Cell	VisibilityController.postMutationBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, RegionObserver.MutationType opType, Mutation mutation, Cell oldCell, Cell newCell)
void	VisibilityController.postOpen(ObserverContext<RegionCoprocessorEnvironment> e) Region related hooks
void	VisibilityController.postScannerClose(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s)
RegionScanner	VisibilityController.postScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Scan scan, RegionScanner s)
Result	VisibilityController.preAppend(ObserverContext<RegionCoprocessorEnvironment> e, Append append)
void	VisibilityController.preBatchMutate(ObserverContext<RegionCoprocessorEnvironment> c, MiniBatchOperationInProgress<Mutation> miniBatchOp)
void	VisibilityController.preGetOp(ObserverContext<RegionCoprocessorEnvironment> e, Get get, List<Cell> results)
Result	VisibilityController.preIncrement(ObserverContext<RegionCoprocessorEnvironment> e, Increment increment)
void	VisibilityController.prePrepareTimeStampForDeleteVersion(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation delete, Cell cell, byte[] byteNow, Get get)
void	VisibilityController.preScannerClose(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s)
boolean	VisibilityController.preScannerNext(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s, List<Result> result, int limit, boolean hasNext)
RegionScanner	VisibilityController.preScannerOpen(ObserverContext<RegionCoprocessorEnvironment> e, Scan scan, RegionScanner s)

Uses of RegionCoprocessorEnvironment in org.apache.hadoop.hbase.tool

Method parameters in org.apache.hadoop.hbase.tool with type arguments of type RegionCoprocessorEnvironment

Modifier and Type	Method and Description
void	WriteSinkCoprocessor.preBatchMutate(ObserverContext<RegionCoprocessorEnvironment> c, MiniBatchOperationInProgress<Mutation> miniBatchOp)
void	WriteSinkCoprocessor.preOpen(ObserverContext<RegionCoprocessorEnvironment> e)