Uses of Interface
org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment
Package
Description
Restrict the domain of a data attribute, often times to fulfill business rules/requirements.
Table of Contents
-
Uses of RegionCoprocessorEnvironment in org.apache.hadoop.hbase.backup
Modifier and TypeMethodDescriptionvoid
BackupObserver.postBulkLoadHFile
(ObserverContext<RegionCoprocessorEnvironment> ctx, List<Pair<byte[], String>> stagingFamilyPaths, Map<byte[], List<org.apache.hadoop.fs.Path>> finalPaths) void
BackupObserver.preCommitStoreFile
(ObserverContext<RegionCoprocessorEnvironment> ctx, byte[] family, List<Pair<org.apache.hadoop.fs.Path, org.apache.hadoop.fs.Path>> pairs) -
Uses of RegionCoprocessorEnvironment in org.apache.hadoop.hbase.constraint
Modifier and TypeMethodDescriptionvoid
ConstraintProcessor.prePut
(ObserverContext<RegionCoprocessorEnvironment> e, Put put, WALEdit edit, Durability durability) -
Uses of RegionCoprocessorEnvironment in org.apache.hadoop.hbase.coprocessor
Modifier and TypeFieldDescriptionprivate RegionCoprocessorEnvironment
BaseRowProcessorEndpoint.env
private RegionCoprocessorEnvironment
MultiRowMutationEndpoint.env
Modifier and TypeMethodDescriptionprivate boolean
MetaTableMetrics.ExampleRegionObserverMeta.isMetaTableOp
(ObserverContext<RegionCoprocessorEnvironment> e) default Result
RegionObserver.postAppend
(ObserverContext<RegionCoprocessorEnvironment> c, Append append, Result result) Deprecated.since 2.5.0 and will be removed in 4.0.0.default Result
RegionObserver.postAppend
(ObserverContext<RegionCoprocessorEnvironment> c, Append append, Result result, WALEdit edit) Called after AppendRegionObserver.postAppendBeforeWAL
(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) Called after a list of new cells has been created during an append operation, but before they are committed to the WAL or memstore.default void
RegionObserver.postBatchMutate
(ObserverContext<RegionCoprocessorEnvironment> c, MiniBatchOperationInProgress<Mutation> miniBatchOp) This will be called after applying a batch of Mutations on a region.default void
RegionObserver.postBatchMutateIndispensably
(ObserverContext<RegionCoprocessorEnvironment> ctx, MiniBatchOperationInProgress<Mutation> miniBatchOp, boolean success) Called after the completion of batch put/delete/increment/append and will be called even if the batch operation fails.default void
RegionObserver.postBulkLoadHFile
(ObserverContext<RegionCoprocessorEnvironment> ctx, List<Pair<byte[], String>> stagingFamilyPaths, Map<byte[], List<org.apache.hadoop.fs.Path>> finalPaths) Called after bulkLoadHFile.default boolean
RegionObserver.postCheckAndDelete
(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Delete delete, boolean result) Deprecated.since 2.4.0 and will be removed in 4.0.0.default boolean
RegionObserver.postCheckAndDelete
(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, Filter filter, Delete delete, boolean result) Deprecated.since 2.4.0 and will be removed in 4.0.0.default CheckAndMutateResult
RegionObserver.postCheckAndMutate
(ObserverContext<RegionCoprocessorEnvironment> c, CheckAndMutate checkAndMutate, CheckAndMutateResult result) Called after checkAndMutatedefault boolean
RegionObserver.postCheckAndPut
(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Put put, boolean result) Deprecated.since 2.4.0 and will be removed in 4.0.0.default boolean
RegionObserver.postCheckAndPut
(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, Filter filter, Put put, boolean result) Deprecated.since 2.4.0 and will be removed in 4.0.0.default void
RegionObserver.postClose
(ObserverContext<RegionCoprocessorEnvironment> c, boolean abortRequested) Called after the region is reported as closed to the master.default void
RegionObserver.postCloseRegionOperation
(ObserverContext<RegionCoprocessorEnvironment> ctx, Region.Operation operation) Called after releasing read lock inRegion.closeRegionOperation()
.default void
RegionObserver.postCommitStoreFile
(ObserverContext<RegionCoprocessorEnvironment> ctx, byte[] family, org.apache.hadoop.fs.Path srcPath, org.apache.hadoop.fs.Path dstPath) Called after moving bulk loaded hfile to region directory.default void
RegionObserver.postCompact
(ObserverContext<RegionCoprocessorEnvironment> c, Store store, StoreFile resultFile, CompactionLifeCycleTracker tracker, CompactionRequest request) Called after compaction has completed and the new store file has been moved in to place.default void
RegionObserver.postCompactSelection
(ObserverContext<RegionCoprocessorEnvironment> c, Store store, List<? extends StoreFile> selected, CompactionLifeCycleTracker tracker, CompactionRequest request) Called after theStoreFile
s to compact have been selected from the available candidates.default void
RegionObserver.postDelete
(ObserverContext<RegionCoprocessorEnvironment> c, Delete delete, WALEdit edit) Called after the client deletes a value.default void
RegionObserver.postDelete
(ObserverContext<RegionCoprocessorEnvironment> c, Delete delete, WALEdit edit, Durability durability) Deprecated.since 2.5.0 and will be removed in 4.0.0.default 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.default boolean
RegionObserver.postExists
(ObserverContext<RegionCoprocessorEnvironment> c, Get get, boolean exists) Called after the client tests for existence using a Get.default void
RegionObserver.postFlush
(ObserverContext<RegionCoprocessorEnvironment> c, FlushLifeCycleTracker tracker) Called after the memstore is flushed to disk.default void
RegionObserver.postFlush
(ObserverContext<RegionCoprocessorEnvironment> c, Store store, StoreFile resultFile, FlushLifeCycleTracker tracker) Called after a Store's memstore is flushed to disk.default void
RegionObserver.postGetOp
(ObserverContext<RegionCoprocessorEnvironment> c, Get get, List<Cell> result) Called after the client performs a Getdefault Result
RegionObserver.postIncrement
(ObserverContext<RegionCoprocessorEnvironment> c, Increment increment, Result result) Deprecated.since 2.5.0 and will be removed in 4.0.0.default Result
RegionObserver.postIncrement
(ObserverContext<RegionCoprocessorEnvironment> c, Increment increment, Result result, WALEdit edit) Called after incrementRegionObserver.postIncrementBeforeWAL
(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) Called after a list of new cells has been created during an increment operation, but before they are committed to the WAL or memstore.default DeleteTracker
RegionObserver.postInstantiateDeleteTracker
(ObserverContext<RegionCoprocessorEnvironment> ctx, DeleteTracker delTracker) Deprecated.Since 2.0 with out any replacement and will be removed in 3.0default void
RegionObserver.postMemStoreCompaction
(ObserverContext<RegionCoprocessorEnvironment> c, Store store) Called after the in memory compaction is finished.default Cell
RegionObserver.postMutationBeforeWAL
(ObserverContext<RegionCoprocessorEnvironment> ctx, RegionObserver.MutationType opType, Mutation mutation, Cell oldCell, Cell newCell) Deprecated.since 2.2.0 and will be removedin 4.0.0.default void
RegionObserver.postOpen
(ObserverContext<RegionCoprocessorEnvironment> c) Called after the region is reported as open to the master.default void
RegionObserver.postPut
(ObserverContext<RegionCoprocessorEnvironment> c, Put put, WALEdit edit) Called after the client stores a value.default void
RegionObserver.postPut
(ObserverContext<RegionCoprocessorEnvironment> c, Put put, WALEdit edit, Durability durability) Deprecated.since 2.5.0 and will be removed in 4.0.0.default void
RegionObserver.postReplayWALs
(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, RegionInfo info, org.apache.hadoop.fs.Path edits) Called after replaying WALs for this region.default void
RegionObserver.postScannerClose
(ObserverContext<RegionCoprocessorEnvironment> ctx, InternalScanner s) Called after the client closes a scanner.default boolean
RegionObserver.postScannerFilterRow
(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s, Cell curRowCell, boolean hasMore) This will be called by the scan flow when the current scanned row is being filtered out by the filter.default 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.default RegionScanner
RegionObserver.postScannerOpen
(ObserverContext<RegionCoprocessorEnvironment> c, Scan scan, RegionScanner s) Called after the client opens a new scanner.default void
RegionObserver.postStartRegionOperation
(ObserverContext<RegionCoprocessorEnvironment> ctx, Region.Operation operation) This will be called for region operations where read lock is acquired inRegion.startRegionOperation()
.default StoreFileReader
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, StoreFileReader reader) Deprecated.For Phoenix only, StoreFileReader is not a stable interface.default void
RegionObserver.postWALRestore
(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, RegionInfo info, WALKey logKey, WALEdit logEdit) Called after aWALEdit
replayed for this region.default Result
RegionObserver.preAppend
(ObserverContext<RegionCoprocessorEnvironment> c, Append append) Deprecated.since 2.5.0 and will be removed in 4.0.0.default Result
RegionObserver.preAppend
(ObserverContext<RegionCoprocessorEnvironment> c, Append append, WALEdit edit) Called before Append.default Result
RegionObserver.preAppendAfterRowLock
(ObserverContext<RegionCoprocessorEnvironment> c, Append append) Deprecated.since 2.5.0 and will be removed in 4.0.0.default void
RegionObserver.preBatchMutate
(ObserverContext<RegionCoprocessorEnvironment> c, MiniBatchOperationInProgress<Mutation> miniBatchOp) This will be called for every batch mutation operation happening at the server.default void
RegionObserver.preBulkLoadHFile
(ObserverContext<RegionCoprocessorEnvironment> ctx, List<Pair<byte[], String>> familyPaths) Called before bulkLoadHFile.default boolean
RegionObserver.preCheckAndDelete
(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Delete delete, boolean result) Deprecated.since 2.4.0 and will be removed in 4.0.0.default boolean
RegionObserver.preCheckAndDelete
(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, Filter filter, Delete delete, boolean result) Deprecated.since 2.4.0 and will be removed in 4.0.0.default boolean
RegionObserver.preCheckAndDeleteAfterRowLock
(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Delete delete, boolean result) Deprecated.since 2.4.0 and will be removed in 4.0.0.default boolean
RegionObserver.preCheckAndDeleteAfterRowLock
(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, Filter filter, Delete delete, boolean result) Deprecated.since 2.4.0 and will be removed in 4.0.0.default CheckAndMutateResult
RegionObserver.preCheckAndMutate
(ObserverContext<RegionCoprocessorEnvironment> c, CheckAndMutate checkAndMutate, CheckAndMutateResult result) Called before checkAndMutatedefault CheckAndMutateResult
RegionObserver.preCheckAndMutateAfterRowLock
(ObserverContext<RegionCoprocessorEnvironment> c, CheckAndMutate checkAndMutate, CheckAndMutateResult result) Called before checkAndDelete but after acquiring rowlock.default boolean
RegionObserver.preCheckAndPut
(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Put put, boolean result) Deprecated.since 2.4.0 and will be removed in 4.0.0.default boolean
RegionObserver.preCheckAndPut
(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, Filter filter, Put put, boolean result) Deprecated.since 2.4.0 and will be removed in 4.0.0.default boolean
RegionObserver.preCheckAndPutAfterRowLock
(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Put put, boolean result) Deprecated.since 2.4.0 and will be removed in 4.0.0.default boolean
RegionObserver.preCheckAndPutAfterRowLock
(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, Filter filter, Put put, boolean result) Deprecated.since 2.4.0 and will be removed in 4.0.0.default void
BulkLoadObserver.preCleanupBulkLoad
(ObserverContext<RegionCoprocessorEnvironment> ctx) Called as part of SecureBulkLoadEndpoint.cleanupBulkLoad() RPC call.default void
RegionObserver.preClose
(ObserverContext<RegionCoprocessorEnvironment> c, boolean abortRequested) Called before the region is reported as closed to the master.default void
RegionObserver.preCommitStoreFile
(ObserverContext<RegionCoprocessorEnvironment> ctx, byte[] family, List<Pair<org.apache.hadoop.fs.Path, org.apache.hadoop.fs.Path>> pairs) Called before moving bulk loaded hfile to region directory.default InternalScanner
RegionObserver.preCompact
(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request) Called prior to writing theStoreFile
s selected for compaction into a newStoreFile
.default void
RegionObserver.preCompactScannerOpen
(ObserverContext<RegionCoprocessorEnvironment> c, Store store, ScanType scanType, ScanOptions options, CompactionLifeCycleTracker tracker, CompactionRequest request) Called before we open store scanner for compaction.default void
RegionObserver.preCompactSelection
(ObserverContext<RegionCoprocessorEnvironment> c, Store store, List<? extends StoreFile> candidates, CompactionLifeCycleTracker tracker) Called prior to selecting theStoreFiles
to compact from the list of available candidates.void
MetaTableMetrics.ExampleRegionObserverMeta.preDelete
(ObserverContext<RegionCoprocessorEnvironment> e, Delete delete, WALEdit edit, Durability durability) default void
RegionObserver.preDelete
(ObserverContext<RegionCoprocessorEnvironment> c, Delete delete, WALEdit edit) Called before the client deletes a value.default void
RegionObserver.preDelete
(ObserverContext<RegionCoprocessorEnvironment> c, Delete delete, WALEdit edit, Durability durability) Deprecated.since 2.5.0 and will be removed in 4.0.0.default 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.default boolean
RegionObserver.preExists
(ObserverContext<RegionCoprocessorEnvironment> c, Get get, boolean exists) Called before the client tests for existence using a Get.default void
RegionObserver.preFlush
(ObserverContext<RegionCoprocessorEnvironment> c, FlushLifeCycleTracker tracker) Called before the memstore is flushed to disk.default InternalScanner
RegionObserver.preFlush
(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, FlushLifeCycleTracker tracker) Called before a Store's memstore is flushed to disk.default void
RegionObserver.preFlushScannerOpen
(ObserverContext<RegionCoprocessorEnvironment> c, Store store, ScanOptions options, FlushLifeCycleTracker tracker) Called before we open store scanner for flush.void
MetaTableMetrics.ExampleRegionObserverMeta.preGetOp
(ObserverContext<RegionCoprocessorEnvironment> e, Get get, List<Cell> results) default void
RegionObserver.preGetOp
(ObserverContext<RegionCoprocessorEnvironment> c, Get get, List<Cell> result) Called before the client performs a Getdefault Result
RegionObserver.preIncrement
(ObserverContext<RegionCoprocessorEnvironment> c, Increment increment) Deprecated.since 2.5.0 and will be removed in 4.0.0.default Result
RegionObserver.preIncrement
(ObserverContext<RegionCoprocessorEnvironment> c, Increment increment, WALEdit edit) Called before Increment.default Result
RegionObserver.preIncrementAfterRowLock
(ObserverContext<RegionCoprocessorEnvironment> c, Increment increment) Deprecated.since 2.5.0 and will be removed in 4.0.0.default void
RegionObserver.preMemStoreCompaction
(ObserverContext<RegionCoprocessorEnvironment> c, Store store) Called before in memory compaction started.default InternalScanner
RegionObserver.preMemStoreCompactionCompact
(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner) Called before we do in memory compaction.default void
RegionObserver.preMemStoreCompactionCompactScannerOpen
(ObserverContext<RegionCoprocessorEnvironment> c, Store store, ScanOptions options) Called before we open store scanner for in memory compaction.default void
RegionObserver.preOpen
(ObserverContext<RegionCoprocessorEnvironment> c) Called before the region is reported as open to the master.default void
BulkLoadObserver.prePrepareBulkLoad
(ObserverContext<RegionCoprocessorEnvironment> ctx) Called as part of SecureBulkLoadEndpoint.prepareBulkLoad() RPC call.default void
RegionObserver.prePrepareTimeStampForDeleteVersion
(ObserverContext<RegionCoprocessorEnvironment> c, Mutation mutation, Cell cell, byte[] byteNow, Get get) Deprecated.Since hbase-2.0.0.void
MetaTableMetrics.ExampleRegionObserverMeta.prePut
(ObserverContext<RegionCoprocessorEnvironment> e, Put put, WALEdit edit, Durability durability) default void
RegionObserver.prePut
(ObserverContext<RegionCoprocessorEnvironment> c, Put put, WALEdit edit) Called before the client stores a value.default void
RegionObserver.prePut
(ObserverContext<RegionCoprocessorEnvironment> c, Put put, WALEdit edit, Durability durability) Deprecated.since 2.5.0 and will be removed in 4.0.0.default void
RegionObserver.preReplayWALs
(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, RegionInfo info, org.apache.hadoop.fs.Path edits) Called before replaying WALs for this region.default void
RegionObserver.preScannerClose
(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s) Called before the client closes a scanner.default 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.default void
RegionObserver.preScannerOpen
(ObserverContext<RegionCoprocessorEnvironment> c, Scan scan) Called before the client opens a new scanner.default StoreFileReader
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, StoreFileReader reader) Deprecated.For Phoenix only, StoreFileReader is not a stable interface.default void
RegionObserver.preStoreScannerOpen
(ObserverContext<RegionCoprocessorEnvironment> ctx, Store store, ScanOptions options) Called before a store opens a new scanner.default void
RegionObserver.preWALAppend
(ObserverContext<RegionCoprocessorEnvironment> ctx, WALKey key, WALEdit edit) Called just before the WAL Entry is appended to the WAL.default void
RegionObserver.preWALRestore
(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, RegionInfo info, WALKey logKey, WALEdit logEdit) Called before aWALEdit
replayed for this region.private void
MetaTableMetrics.ExampleRegionObserverMeta.registerAndMarkMetrics
(ObserverContext<RegionCoprocessorEnvironment> e, Row row) -
Uses of RegionCoprocessorEnvironment in org.apache.hadoop.hbase.coprocessor.example
Modifier and TypeFieldDescriptionprivate RegionCoprocessorEnvironment
BulkDeleteEndpoint.env
private RegionCoprocessorEnvironment
RefreshHFilesEndpoint.env
private RegionCoprocessorEnvironment
RowCountEndpoint.env
Modifier and TypeMethodDescriptionvoid
ExampleRegionObserverWithMetrics.ExampleRegionObserver.postCompactSelection
(ObserverContext<RegionCoprocessorEnvironment> c, Store store, List<? extends StoreFile> selected, CompactionLifeCycleTracker tracker, CompactionRequest request) void
ExampleRegionObserverWithMetrics.ExampleRegionObserver.postFlush
(ObserverContext<RegionCoprocessorEnvironment> c, FlushLifeCycleTracker tracker) void
ExampleRegionObserverWithMetrics.ExampleRegionObserver.postFlush
(ObserverContext<RegionCoprocessorEnvironment> c, Store store, StoreFile resultFile, FlushLifeCycleTracker tracker) void
ExampleRegionObserverWithMetrics.ExampleRegionObserver.postGetOp
(ObserverContext<RegionCoprocessorEnvironment> e, Get get, List<Cell> results) ValueRewritingObserver.preCompact
(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request) WriteHeavyIncrementObserver.preCompact
(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request) void
WriteHeavyIncrementObserver.preCompactScannerOpen
(ObserverContext<RegionCoprocessorEnvironment> c, Store store, ScanType scanType, ScanOptions options, CompactionLifeCycleTracker tracker, CompactionRequest request) void
ZooKeeperScanPolicyObserver.preCompactScannerOpen
(ObserverContext<RegionCoprocessorEnvironment> c, Store store, ScanType scanType, ScanOptions options, CompactionLifeCycleTracker tracker, CompactionRequest request) WriteHeavyIncrementObserver.preFlush
(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, FlushLifeCycleTracker tracker) void
WriteHeavyIncrementObserver.preFlushScannerOpen
(ObserverContext<RegionCoprocessorEnvironment> c, Store store, ScanOptions options, FlushLifeCycleTracker tracker) void
ZooKeeperScanPolicyObserver.preFlushScannerOpen
(ObserverContext<RegionCoprocessorEnvironment> c, Store store, ScanOptions options, FlushLifeCycleTracker tracker) void
ExampleRegionObserverWithMetrics.ExampleRegionObserver.preGetOp
(ObserverContext<RegionCoprocessorEnvironment> e, Get get, List<Cell> results) void
WriteHeavyIncrementObserver.preGetOp
(ObserverContext<RegionCoprocessorEnvironment> c, Get get, List<Cell> result) WriteHeavyIncrementObserver.preIncrement
(ObserverContext<RegionCoprocessorEnvironment> c, Increment increment) WriteHeavyIncrementObserver.preMemStoreCompactionCompact
(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner) void
WriteHeavyIncrementObserver.preMemStoreCompactionCompactScannerOpen
(ObserverContext<RegionCoprocessorEnvironment> c, Store store, ScanOptions options) void
ScanModifyingObserver.preScannerOpen
(ObserverContext<RegionCoprocessorEnvironment> c, Scan scan) void
WriteHeavyIncrementObserver.preStoreScannerOpen
(ObserverContext<RegionCoprocessorEnvironment> ctx, Store store, ScanOptions options) -
Uses of RegionCoprocessorEnvironment in org.apache.hadoop.hbase.regionserver
Modifier and TypeClassDescriptionprivate static class
Encapsulation of the environment of each coprocessorprivate static class
Special version of RegionEnvironment that exposes RegionServerServices for Core Coprocessors only. -
Uses of RegionCoprocessorEnvironment in org.apache.hadoop.hbase.replication.regionserver
Modifier and TypeMethodDescriptionvoid
ReplicationObserver.preCommitStoreFile
(ObserverContext<RegionCoprocessorEnvironment> ctx, byte[] family, List<Pair<org.apache.hadoop.fs.Path, org.apache.hadoop.fs.Path>> pairs) -
Uses of RegionCoprocessorEnvironment in org.apache.hadoop.hbase.security.access
Modifier and TypeFieldDescriptionprivate RegionCoprocessorEnvironment
AccessController.regionEnv
defined only for Endpoint implementation, so it can have way to access region servicesModifier and TypeMethodDescriptionprivate boolean
AccessController.checkCoveringPermission
(User user, AccessController.OpType request, RegionCoprocessorEnvironment e, byte[] row, Map<byte[], ? extends Collection<?>> familyMap, long opTs, Permission.Action... actions) Determine if cell ACLs covered by the operation grant access.private Region
AccessController.getRegion
(RegionCoprocessorEnvironment e) private TableName
AccessController.getTableName
(RegionCoprocessorEnvironment e) private boolean
AccessController.hasFamilyQualifierPermission
(User user, Permission.Action perm, RegionCoprocessorEnvironment env, Map<byte[], ? extends Collection<byte[]>> familyMap) Returnstrue
if the current user is allowed the given action over at least one of the column qualifiers in the given column families.private void
AccessController.initialize
(RegionCoprocessorEnvironment e) private AuthResult
AccessController.permissionGranted
(AccessController.OpType opType, User user, RegionCoprocessorEnvironment e, Map<byte[], ? extends Collection<?>> families, Permission.Action... actions) Check the current user for authorization to perform a specific action against the given set of row data.private void
AccessController.updateACL
(RegionCoprocessorEnvironment e, Map<byte[], List<Cell>> familyMap) Writes all table ACLs for the tables in the given Map up into ZooKeeper znodes.Modifier and TypeMethodDescriptionprivate void
AccessController.internalPreRead
(ObserverContext<RegionCoprocessorEnvironment> c, Query query, AccessController.OpType opType) AccessController.postAppendBeforeWAL
(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) 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) AccessController.postIncrementBeforeWAL
(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) 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) AccessController.postScannerOpen
(ObserverContext<RegionCoprocessorEnvironment> c, Scan scan, RegionScanner s) AccessController.preAppend
(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 or ADMIN privileges on the Column Families involved in the bulkLoadHFile request.boolean
AccessController.preCheckAndDelete
(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Delete delete, boolean result) boolean
AccessController.preCheckAndDeleteAfterRowLock
(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Delete delete, boolean result) boolean
AccessController.preCheckAndPut
(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Put put, boolean result) boolean
AccessController.preCheckAndPutAfterRowLock
(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator opp, ByteArrayComparable comparator, Put put, boolean result) void
AccessController.preCleanupBulkLoad
(ObserverContext<RegionCoprocessorEnvironment> ctx) Authorization security check for SecureBulkLoadProtocol.cleanupBulkLoad()void
AccessController.preClose
(ObserverContext<RegionCoprocessorEnvironment> c, boolean abortRequested) AccessController.preCompact
(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request) 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> c, FlushLifeCycleTracker tracker) void
AccessController.preGetOp
(ObserverContext<RegionCoprocessorEnvironment> c, Get get, List<Cell> result) AccessController.preIncrement
(ObserverContext<RegionCoprocessorEnvironment> c, Increment increment) void
AccessController.preOpen
(ObserverContext<RegionCoprocessorEnvironment> c) void
AccessController.prePrepareBulkLoad
(ObserverContext<RegionCoprocessorEnvironment> ctx) 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) void
AccessController.preScannerOpen
(ObserverContext<RegionCoprocessorEnvironment> c, Scan scan) -
Uses of RegionCoprocessorEnvironment in org.apache.hadoop.hbase.security.visibility
Modifier and TypeMethodDescriptionvoid
DefaultVisibilityLabelServiceImpl.init
(RegionCoprocessorEnvironment e) void
VisibilityLabelService.init
(RegionCoprocessorEnvironment e) System calls this after opening of regions.private void
VisibilityController.initVisibilityLabelService
(RegionCoprocessorEnvironment env) Modifier and TypeMethodDescriptionVisibilityController.postAppendBeforeWAL
(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) VisibilityController.postIncrementBeforeWAL
(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) VisibilityController.postInstantiateDeleteTracker
(ObserverContext<RegionCoprocessorEnvironment> ctx, DeleteTracker delTracker) void
VisibilityController.postOpen
(ObserverContext<RegionCoprocessorEnvironment> e) Region related hooksvoid
VisibilityController.postScannerClose
(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s) VisibilityController.postScannerOpen
(ObserverContext<RegionCoprocessorEnvironment> c, Scan scan, RegionScanner s) void
VisibilityController.preBatchMutate
(ObserverContext<RegionCoprocessorEnvironment> c, MiniBatchOperationInProgress<Mutation> miniBatchOp) void
VisibilityController.preGetOp
(ObserverContext<RegionCoprocessorEnvironment> e, Get get, List<Cell> results) 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) void
VisibilityController.preScannerOpen
(ObserverContext<RegionCoprocessorEnvironment> e, Scan scan) -
Uses of RegionCoprocessorEnvironment in org.apache.hadoop.hbase.tool
Modifier and TypeMethodDescriptionvoid
WriteSinkCoprocessor.preBatchMutate
(ObserverContext<RegionCoprocessorEnvironment> c, MiniBatchOperationInProgress<Mutation> miniBatchOp) void
WriteSinkCoprocessor.preOpen
(ObserverContext<RegionCoprocessorEnvironment> e)