Uses of Interface
org.apache.hadoop.hbase.coprocessor.ObserverContext
Package
Description
Restrict the domain of a data attribute, often times to fulfill business rules/requirements.
Table of Contents
-
Uses of ObserverContext in org.apache.hadoop.hbase.backup
Modifier and TypeMethodDescriptionvoid
BackupObserver.postBulkLoadHFile
(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, List<Pair<byte[], String>> stagingFamilyPaths, Map<byte[], List<org.apache.hadoop.fs.Path>> finalPaths) void
BackupObserver.preCommitStoreFile
(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, byte[] family, List<Pair<org.apache.hadoop.fs.Path, org.apache.hadoop.fs.Path>> pairs) -
Uses of ObserverContext in org.apache.hadoop.hbase.constraint
Modifier and TypeMethodDescriptionvoid
ConstraintProcessor.prePut
(ObserverContext<? extends RegionCoprocessorEnvironment> e, Put put, WALEdit edit, Durability durability) -
Uses of ObserverContext in org.apache.hadoop.hbase.coprocessor
Modifier and TypeClassDescriptionprivate class
class
class
class
ObserverContextImpl<E extends CoprocessorEnvironment>
This is the only implementation ofObserverContext
, which serves as the interface for third-party Coprocessor developers.Modifier and TypeMethodDescriptionstatic <E extends CoprocessorEnvironment>
ObserverContext<E>ObserverContextImpl.createAndPrepare
(E env) Deprecated.Modifier and TypeMethodDescriptionprivate boolean
MetaTableMetrics.ExampleRegionObserverMeta.isMetaTableOp
(ObserverContext<? extends RegionCoprocessorEnvironment> e) default void
MasterObserver.postAbortProcedure
(ObserverContext<MasterCoprocessorEnvironment> ctx) Called after a abortProcedure request has been processed.default void
MasterObserver.postAddReplicationPeer
(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId, ReplicationPeerConfig peerConfig) Called after add a replication peerdefault void
MasterObserver.postAddRSGroup
(ObserverContext<MasterCoprocessorEnvironment> ctx, String name) Called after a new region server group is addeddefault Result
RegionObserver.postAppend
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Append append, Result result) Deprecated.since 3.0.0 and will be removed in 4.0.0.default Result
RegionObserver.postAppend
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Append append, Result result, WALEdit edit) Called after AppendRegionObserver.postAppendBeforeWAL
(ObserverContext<? extends 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
MasterObserver.postAssign
(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo regionInfo) Called after the region assignment has been requested.default void
MasterObserver.postBalance
(ObserverContext<MasterCoprocessorEnvironment> ctx, BalanceRequest request, List<RegionPlan> plans) Called after the balancing plan has been submitted.default void
MasterObserver.postBalanceRSGroup
(ObserverContext<MasterCoprocessorEnvironment> ctx, String groupName, BalanceRequest request, BalanceResponse response) Called after a region server group is removeddefault void
MasterObserver.postBalanceSwitch
(ObserverContext<MasterCoprocessorEnvironment> ctx, boolean oldValue, boolean newValue) Called after the flag to enable/disable balancing has changed.default void
RegionObserver.postBatchMutate
(ObserverContext<? extends RegionCoprocessorEnvironment> c, MiniBatchOperationInProgress<Mutation> miniBatchOp) This will be called after applying a batch of Mutations on a region.default void
RegionObserver.postBatchMutateIndispensably
(ObserverContext<? extends 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<? extends RegionCoprocessorEnvironment> ctx, List<Pair<byte[], String>> stagingFamilyPaths, Map<byte[], List<org.apache.hadoop.fs.Path>> finalPaths) Called after bulkLoadHFile.default boolean
RegionObserver.postCheckAndDelete
(ObserverContext<? extends RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Delete delete, boolean result) Deprecated.since 3.0.0 and will be removed in 4.0.0.default boolean
RegionObserver.postCheckAndDelete
(ObserverContext<? extends RegionCoprocessorEnvironment> c, byte[] row, Filter filter, Delete delete, boolean result) Deprecated.since 3.0.0 and will be removed in 4.0.0.default CheckAndMutateResult
RegionObserver.postCheckAndMutate
(ObserverContext<? extends RegionCoprocessorEnvironment> c, CheckAndMutate checkAndMutate, CheckAndMutateResult result) Called after checkAndMutatedefault boolean
RegionObserver.postCheckAndPut
(ObserverContext<? extends RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Put put, boolean result) Deprecated.since 3.0.0 and will be removed in 4.0.0.default boolean
RegionObserver.postCheckAndPut
(ObserverContext<? extends RegionCoprocessorEnvironment> c, byte[] row, Filter filter, Put put, boolean result) Deprecated.since 3.0.0 and will be removed in 4.0.0.default void
RegionServerObserver.postClearCompactionQueues
(ObserverContext<RegionServerCoprocessorEnvironment> ctx) This will be called after clearing compaction queuesdefault void
MasterObserver.postClearDeadServers
(ObserverContext<MasterCoprocessorEnvironment> ctx, List<ServerName> servers, List<ServerName> notClearedServers) Called after clear dead region servers.default void
RegionServerObserver.postClearRegionBlockCache
(ObserverContext<RegionServerCoprocessorEnvironment> ctx, CacheEvictionStats stats) Called after clearing the block caches for one or more regionsdefault void
MasterObserver.postCloneSnapshot
(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot, TableDescriptor tableDescriptor) Called after a snapshot clone operation has been requested.default void
RegionObserver.postClose
(ObserverContext<? extends RegionCoprocessorEnvironment> c, boolean abortRequested) Called after the region is reported as closed to the master.default void
RegionObserver.postCloseRegionOperation
(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, Region.Operation operation) Called after releasing read lock inRegion.closeRegionOperation()
.default void
RegionObserver.postCommitStoreFile
(ObserverContext<? extends 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<? extends 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<? extends 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
MasterObserver.postCompletedCreateTableAction
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableDescriptor desc, RegionInfo[] regions) Called after the createTable operation has been requested.default void
MasterObserver.postCompletedDeleteTableAction
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called afterHMaster
deletes a table.default void
MasterObserver.postCompletedDisableTableAction
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called after the disableTable operation has been requested.default void
MasterObserver.postCompletedEnableTableAction
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called after the enableTable operation has been requested.default void
MasterObserver.postCompletedMergeRegionsAction
(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo[] regionsToMerge, RegionInfo mergedRegion) called after the regions merge.default void
MasterObserver.postCompletedModifyTableAction
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, TableDescriptor oldDescriptor, TableDescriptor currentDescriptor) Called after to modifying a table's properties.default void
MasterObserver.postCompletedSnapshotAction
(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot, TableDescriptor tableDescriptor) Called after the snapshot operation has been completed.default void
MasterObserver.postCompletedSplitRegionAction
(ObserverContext<MasterCoprocessorEnvironment> c, RegionInfo regionInfoA, RegionInfo regionInfoB) Called after the region is split.default void
MasterObserver.postCompletedTruncateTableAction
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called afterHMaster
truncates a table.default void
MasterObserver.postCreateNamespace
(ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor ns) Called after the createNamespace operation has been requested.default ReplicationEndpoint
RegionServerObserver.postCreateReplicationEndPoint
(ObserverContext<RegionServerCoprocessorEnvironment> ctx, ReplicationEndpoint endpoint) This will be called after the replication endpoint is instantiated.default void
MasterObserver.postCreateTable
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableDescriptor desc, RegionInfo[] regions) Called after the createTable operation has been requested.default void
MasterObserver.postDecommissionRegionServers
(ObserverContext<MasterCoprocessorEnvironment> ctx, List<ServerName> servers, boolean offload) Called after decommission region servers.default void
RegionObserver.postDelete
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Delete delete, WALEdit edit) Called after the client deletes a value.default void
RegionObserver.postDelete
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Delete delete, WALEdit edit, Durability durability) Deprecated.since 3.0.0 and will be removed in 4.0.0.default void
MasterObserver.postDeleteNamespace
(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace) Called after the deleteNamespace operation has been requested.default void
MasterObserver.postDeleteSnapshot
(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot) Called after the delete snapshot operation has been requested.default void
MasterObserver.postDeleteTable
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called after the deleteTable operation has been requested.default void
MasterObserver.postDisableReplicationPeer
(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId) Called after disable a replication peerdefault void
MasterObserver.postDisableTable
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called after the disableTable operation has been requested.default void
MasterObserver.postEnableReplicationPeer
(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId) Called after enable a replication peerdefault void
MasterObserver.postEnableTable
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called after the enableTable operation has been requested.default void
EndpointObserver.postEndpointInvocation
(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, org.apache.hbase.thirdparty.com.google.protobuf.Service service, String methodName, org.apache.hbase.thirdparty.com.google.protobuf.Message request, org.apache.hbase.thirdparty.com.google.protobuf.Message.Builder responseBuilder) Called after an Endpoint service method is invoked.default void
RegionServerObserver.postExecuteProcedures
(ObserverContext<RegionServerCoprocessorEnvironment> ctx) This will be called after executing proceduresdefault boolean
RegionObserver.postExists
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Get get, boolean exists) Called after the client tests for existence using a Get.default void
RegionObserver.postFlush
(ObserverContext<? extends RegionCoprocessorEnvironment> c, FlushLifeCycleTracker tracker) Called after the memstore is flushed to disk.default void
RegionObserver.postFlush
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Store store, StoreFile resultFile, FlushLifeCycleTracker tracker) Called after a Store's memstore is flushed to disk.default void
MasterObserver.postGetClusterMetrics
(ObserverContext<MasterCoprocessorEnvironment> ctx, ClusterMetrics status) Called after get cluster status.default void
MasterObserver.postGetConfiguredNamespacesAndTablesInRSGroup
(ObserverContext<MasterCoprocessorEnvironment> ctx, String groupName) Called after getting the configured namespaces and tables in the region server group.default void
MasterObserver.postGetLocks
(ObserverContext<MasterCoprocessorEnvironment> ctx) Called after a getLocks request has been processed.default void
MasterObserver.postGetNamespaceDescriptor
(ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor ns) Called after a getNamespaceDescriptor request has been processed.default void
RegionObserver.postGetOp
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Get get, List<Cell> result) Called after the client performs a Getdefault void
MasterObserver.postGetProcedures
(ObserverContext<MasterCoprocessorEnvironment> ctx) Called after a getProcedures request has been processed.default void
MasterObserver.postGetReplicationPeerConfig
(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId) Called after get the configured ReplicationPeerConfig for the specified peerdefault void
MasterObserver.postGetRSGroupInfo
(ObserverContext<MasterCoprocessorEnvironment> ctx, String groupName) Called after getting region server group info of the passed groupName.default void
MasterObserver.postGetRSGroupInfoOfServer
(ObserverContext<MasterCoprocessorEnvironment> ctx, Address server) Called after getting region server group info of the passed server.default void
MasterObserver.postGetRSGroupInfoOfTable
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called after getting region server group info of the passed tableName.default void
MasterObserver.postGetTableDescriptors
(ObserverContext<MasterCoprocessorEnvironment> ctx, List<TableName> tableNamesList, List<TableDescriptor> descriptors, String regex) Called after a getTableDescriptors request has been processed.default void
MasterObserver.postGetTableNames
(ObserverContext<MasterCoprocessorEnvironment> ctx, List<TableDescriptor> descriptors, String regex) Called after a getTableNames request has been processed.default void
MasterObserver.postGetUserPermissions
(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, String namespace, TableName tableName, byte[] family, byte[] qualifier) Called after getting user permissions.default void
MasterObserver.postGrant
(ObserverContext<MasterCoprocessorEnvironment> ctx, UserPermission userPermission, boolean mergeExistingPermissions) Called after granting user permissions.default void
MasterObserver.postHasUserPermissions
(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, List<Permission> permissions) Called after checking if user has permissions.default Result
RegionObserver.postIncrement
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Increment increment, Result result) Deprecated.since 3.0.0 and will be removed in 4.0.0.default Result
RegionObserver.postIncrement
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Increment increment, Result result, WALEdit edit) Called after incrementRegionObserver.postIncrementBeforeWAL
(ObserverContext<? extends 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<? extends RegionCoprocessorEnvironment> ctx, DeleteTracker delTracker) Deprecated.Since 2.0.0, will be removed in 4.0.0.default void
MasterObserver.postIsRpcThrottleEnabled
(ObserverContext<MasterCoprocessorEnvironment> ctx, boolean rpcThrottleEnabled) Called after getting if is rpc throttle enabled.default void
MasterObserver.postListDecommissionedRegionServers
(ObserverContext<MasterCoprocessorEnvironment> ctx) Called after list decommissioned region servers.default void
MasterObserver.postListNamespaceDescriptors
(ObserverContext<MasterCoprocessorEnvironment> ctx, List<NamespaceDescriptor> descriptors) Called after a listNamespaceDescriptors request has been processed.default void
MasterObserver.postListNamespaces
(ObserverContext<MasterCoprocessorEnvironment> ctx, List<String> namespaces) Called after a listNamespaces request has been processed.default void
MasterObserver.postListReplicationPeers
(ObserverContext<MasterCoprocessorEnvironment> ctx, String regex) Called after list replication peers.default void
MasterObserver.postListRSGroups
(ObserverContext<MasterCoprocessorEnvironment> ctx) Called after listing region server group information.default void
MasterObserver.postListSnapshot
(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot) Called after listSnapshots request has been processed.default void
MasterObserver.postListTablesInRSGroup
(ObserverContext<MasterCoprocessorEnvironment> ctx, String groupName) Called after listing all tables in the region server group.default void
MasterObserver.postLockHeartbeat
(ObserverContext<MasterCoprocessorEnvironment> ctx) Called after heartbeat to a lock.default void
MasterObserver.postMasterStoreFlush
(ObserverContext<MasterCoprocessorEnvironment> ctx) Called after the master local region memstore is flushed to disk.default void
RegionObserver.postMemStoreCompaction
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Store store) Called after the in memory compaction is finished.default void
MasterObserver.postMergeRegions
(ObserverContext<MasterCoprocessorEnvironment> c, RegionInfo[] regionsToMerge) called after merge regions request.default void
MasterObserver.postMergeRegionsCommitAction
(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo[] regionsToMerge, RegionInfo mergedRegion) This will be called after META step as part of regions merge transaction.default void
MasterObserver.postModifyColumnFamilyStoreFileTracker
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, byte[] family, String dstSFT) Called after modifying a family store file tracker.default void
MasterObserver.postModifyNamespace
(ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor oldNsDescriptor, NamespaceDescriptor currentNsDescriptor) Called after the modifyNamespace operation has been requested.default void
MasterObserver.postModifyTable
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, TableDescriptor oldDescriptor, TableDescriptor currentDescriptor) Called after the modifyTable operation has been requested.default void
MasterObserver.postModifyTableStoreFileTracker
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, String dstSFT) Called after modifying a table's store file tracker.default void
MasterObserver.postMove
(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo region, ServerName srcServer, ServerName destServer) Called after the region move has been requested.default void
MasterObserver.postMoveServers
(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<Address> servers, String targetGroup) Called after servers are moved to target region server groupdefault void
MasterObserver.postMoveServersAndTables
(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<Address> servers, Set<TableName> tables, String targetGroup) Called after servers are moved to target region server groupdefault void
MasterObserver.postMoveTables
(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<TableName> tables, String targetGroup) Called after servers are moved to target region server groupdefault Cell
RegionObserver.postMutationBeforeWAL
(ObserverContext<? extends 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<? extends RegionCoprocessorEnvironment> c) Called after the region is reported as open to the master.default void
RegionObserver.postPut
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Put put, WALEdit edit) Called after the client stores a value.default void
RegionObserver.postPut
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Put put, WALEdit edit, Durability durability) Deprecated.since 3.0.0 and will be removed in 4.0.0.default void
MasterObserver.postRecommissionRegionServer
(ObserverContext<MasterCoprocessorEnvironment> ctx, ServerName server, List<byte[]> encodedRegionNames) Called after recommission region server.default void
MasterObserver.postRegionOffline
(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo regionInfo) Called after the region has been marked offline.default void
MasterObserver.postRemoveReplicationPeer
(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId) Called after remove a replication peerdefault void
MasterObserver.postRemoveRSGroup
(ObserverContext<MasterCoprocessorEnvironment> ctx, String name) Called after a region server group is removeddefault void
MasterObserver.postRemoveServers
(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<Address> servers) Called after servers are removed from rsgroupdefault void
MasterObserver.postRenameRSGroup
(ObserverContext<MasterCoprocessorEnvironment> ctx, String oldName, String newName) Called after rename rsgroup.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
RegionServerObserver.postReplicateLogEntries
(ObserverContext<RegionServerCoprocessorEnvironment> ctx) Deprecated.As of release 2.0.0 with out any replacement, plan to remove in 4.0.0.default void
RegionServerObserver.postReplicationSinkBatchMutate
(ObserverContext<RegionServerCoprocessorEnvironment> ctx, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WALEntry walEntry, Mutation mutation) This will be called after replication sink mutations are executed on the sink table as part of batch call.default void
MasterObserver.postRequestLock
(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace, TableName tableName, RegionInfo[] regionInfos, String description) Called after new LockProcedure is queued.default void
MasterObserver.postRestoreSnapshot
(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot, TableDescriptor tableDescriptor) Called after a snapshot restore operation has been requested.default void
MasterObserver.postRevoke
(ObserverContext<MasterCoprocessorEnvironment> ctx, UserPermission userPermission) Called after revoking user permissions.default void
MasterObserver.postRollBackMergeRegionsAction
(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo[] regionsToMerge) This will be called after the roll back of the regions merge.default void
MasterObserver.postRollBackSplitRegionAction
(ObserverContext<MasterCoprocessorEnvironment> ctx) This will be called after the roll back of the split region is completeddefault void
RegionServerObserver.postRollWALWriterRequest
(ObserverContext<RegionServerCoprocessorEnvironment> ctx) This will be called after executing user request to roll a region server WAL.default void
RegionObserver.postScannerClose
(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, InternalScanner s) Called after the client closes a scanner.default boolean
RegionObserver.postScannerFilterRow
(ObserverContext<? extends 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<? extends 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<? extends RegionCoprocessorEnvironment> c, Scan scan, RegionScanner s) Called after the client opens a new scanner.default void
MasterObserver.postSetNamespaceQuota
(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace, GlobalQuotaSettings quotas) Called after the quota for the namespace is stored.default void
MasterObserver.postSetRegionServerQuota
(ObserverContext<MasterCoprocessorEnvironment> ctx, String regionServer, GlobalQuotaSettings quotas) Called after the quota for the region server is stored.default void
MasterObserver.postSetSplitOrMergeEnabled
(ObserverContext<MasterCoprocessorEnvironment> ctx, boolean newValue, MasterSwitchType switchType) Called after setting split / merge switchdefault void
MasterObserver.postSetTableQuota
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, GlobalQuotaSettings quotas) Called after the quota for the table is stored.default void
MasterObserver.postSetUserQuota
(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, String namespace, GlobalQuotaSettings quotas) Called after the quota for the user on the specified namespace is stored.default void
MasterObserver.postSetUserQuota
(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, GlobalQuotaSettings quotas) Called after the quota for the user is stored.default void
MasterObserver.postSetUserQuota
(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, TableName tableName, GlobalQuotaSettings quotas) Called after the quota for the user on the specified table is stored.default void
MasterObserver.postSnapshot
(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot, TableDescriptor tableDescriptor) Called after the snapshot operation has been requested.default void
MasterObserver.postStartMaster
(ObserverContext<MasterCoprocessorEnvironment> ctx) Called immediately after an active master instance has completed initialization.default void
RegionObserver.postStartRegionOperation
(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, Region.Operation operation) This will be called for region operations where read lock is acquired inRegion.startRegionOperation()
.default StoreFileReader
RegionObserver.postStoreFileReaderOpen
(ObserverContext<? extends 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
MasterObserver.postSwitchExceedThrottleQuota
(ObserverContext<MasterCoprocessorEnvironment> ctx, boolean oldValue, boolean newValue) Called after switching exceed throttle quota state.default void
MasterObserver.postSwitchRpcThrottle
(ObserverContext<MasterCoprocessorEnvironment> ctx, boolean oldValue, boolean newValue) Called after switching rpc throttle enabled state.default void
MasterObserver.postTableFlush
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called after the table memstore is flushed to disk.default void
MasterObserver.postTransitReplicationPeerSyncReplicationState
(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId, SyncReplicationState from, SyncReplicationState to) Called after transit current cluster state for the specified synchronous replication peerdefault void
MasterObserver.postTruncateRegion
(ObserverContext<MasterCoprocessorEnvironment> c, RegionInfo regionInfo) Called after the truncate region procedure is called.default void
MasterObserver.postTruncateRegionAction
(ObserverContext<MasterCoprocessorEnvironment> c, RegionInfo regionInfo) Called post the region is truncated.default void
MasterObserver.postTruncateTable
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called after the truncateTable operation has been requested.default void
MasterObserver.postUnassign
(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo regionInfo) Called after the region unassignment has been requested.default void
MasterObserver.postUpdateMasterConfiguration
(ObserverContext<MasterCoprocessorEnvironment> ctx, org.apache.hadoop.conf.Configuration postReloadConf) Called after reloading the HMaster'sConfiguration
from diskdefault void
RegionServerObserver.postUpdateRegionServerConfiguration
(ObserverContext<RegionServerCoprocessorEnvironment> ctx, org.apache.hadoop.conf.Configuration postReloadConf) Called after reloading the RegionServer'sConfiguration
from diskdefault void
MasterObserver.postUpdateReplicationPeerConfig
(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId, ReplicationPeerConfig peerConfig) Called after update peerConfig for the specified peerdefault void
MasterObserver.postUpdateRSGroupConfig
(ObserverContext<MasterCoprocessorEnvironment> ctx, String groupName, Map<String, String> configuration) Called after update rsgroup config.default void
WALObserver.postWALRoll
(ObserverContext<? extends WALCoprocessorEnvironment> ctx, org.apache.hadoop.fs.Path oldPath, org.apache.hadoop.fs.Path newPath) Called after rolling the current WALdefault void
WALObserver.postWALWrite
(ObserverContext<? extends WALCoprocessorEnvironment> ctx, RegionInfo info, WALKey logKey, WALEdit logEdit) Called after aWALEdit
is writen to WAL.default void
MasterObserver.preAbortProcedure
(ObserverContext<MasterCoprocessorEnvironment> ctx, long procId) Called before a abortProcedure request has been processed.default void
MasterObserver.preAddReplicationPeer
(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId, ReplicationPeerConfig peerConfig) Called before add a replication peerdefault void
MasterObserver.preAddRSGroup
(ObserverContext<MasterCoprocessorEnvironment> ctx, String name) Called before a new region server group is addeddefault Result
RegionObserver.preAppend
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Append append) Deprecated.since 3.0.0 and will be removed in 4.0.0.default Result
RegionObserver.preAppend
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Append append, WALEdit edit) Called before Append.default Result
RegionObserver.preAppendAfterRowLock
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Append append) Deprecated.since 3.0.0 and will be removed in 4.0.0.default void
MasterObserver.preAssign
(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo regionInfo) Called prior to assigning a specific region.default void
MasterObserver.preBalance
(ObserverContext<MasterCoprocessorEnvironment> ctx, BalanceRequest request) Called prior to requesting rebalancing of the cluster regions, though after the initial checks for regions in transition and the balance switch flag.default void
MasterObserver.preBalanceRSGroup
(ObserverContext<MasterCoprocessorEnvironment> ctx, String groupName, BalanceRequest request) Called before a region server group is removeddefault void
MasterObserver.preBalanceSwitch
(ObserverContext<MasterCoprocessorEnvironment> ctx, boolean newValue) Called prior to modifying the flag used to enable/disable region balancing.default void
RegionObserver.preBatchMutate
(ObserverContext<? extends RegionCoprocessorEnvironment> c, MiniBatchOperationInProgress<Mutation> miniBatchOp) This will be called for every batch mutation operation happening at the server.default void
RegionObserver.preBulkLoadHFile
(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, List<Pair<byte[], String>> familyPaths) Called before bulkLoadHFile.default boolean
RegionObserver.preCheckAndDelete
(ObserverContext<? extends RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Delete delete, boolean result) Deprecated.since 3.0.0 and will be removed in 4.0.0.default boolean
RegionObserver.preCheckAndDelete
(ObserverContext<? extends RegionCoprocessorEnvironment> c, byte[] row, Filter filter, Delete delete, boolean result) Deprecated.since 3.0.0 and will be removed in 4.0.0.default boolean
RegionObserver.preCheckAndDeleteAfterRowLock
(ObserverContext<? extends RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Delete delete, boolean result) Deprecated.since 3.0.0 and will be removed in 4.0.0.default boolean
RegionObserver.preCheckAndDeleteAfterRowLock
(ObserverContext<? extends RegionCoprocessorEnvironment> c, byte[] row, Filter filter, Delete delete, boolean result) Deprecated.since 3.0.0 and will be removed in 4.0.0.default CheckAndMutateResult
RegionObserver.preCheckAndMutate
(ObserverContext<? extends RegionCoprocessorEnvironment> c, CheckAndMutate checkAndMutate, CheckAndMutateResult result) Called before checkAndMutatedefault CheckAndMutateResult
RegionObserver.preCheckAndMutateAfterRowLock
(ObserverContext<? extends RegionCoprocessorEnvironment> c, CheckAndMutate checkAndMutate, CheckAndMutateResult result) Called before checkAndDelete but after acquiring rowlock.default boolean
RegionObserver.preCheckAndPut
(ObserverContext<? extends RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Put put, boolean result) Deprecated.since 3.0.0 and will be removed in 4.0.0.default boolean
RegionObserver.preCheckAndPut
(ObserverContext<? extends RegionCoprocessorEnvironment> c, byte[] row, Filter filter, Put put, boolean result) Deprecated.since 3.0.0 and will be removed in 4.0.0.default boolean
RegionObserver.preCheckAndPutAfterRowLock
(ObserverContext<? extends RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Put put, boolean result) Deprecated.since 3.0.0 and will be removed in 4.0.0.default boolean
RegionObserver.preCheckAndPutAfterRowLock
(ObserverContext<? extends RegionCoprocessorEnvironment> c, byte[] row, Filter filter, Put put, boolean result) Deprecated.since 3.0.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
RegionServerObserver.preClearCompactionQueues
(ObserverContext<RegionServerCoprocessorEnvironment> ctx) This will be called before clearing compaction queuesdefault void
MasterObserver.preClearDeadServers
(ObserverContext<MasterCoprocessorEnvironment> ctx) Called before clear dead region servers.default void
RegionServerObserver.preClearRegionBlockCache
(ObserverContext<RegionServerCoprocessorEnvironment> ctx) Called before clearing the block caches for one or more regionsdefault void
MasterObserver.preCloneSnapshot
(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot, TableDescriptor tableDescriptor) Called before a snapshot is cloned.default void
RegionObserver.preClose
(ObserverContext<? extends RegionCoprocessorEnvironment> c, boolean abortRequested) Called before the region is reported as closed to the master.default void
RegionObserver.preCommitStoreFile
(ObserverContext<? extends 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<? extends 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<? extends 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<? extends RegionCoprocessorEnvironment> c, Store store, List<? extends StoreFile> candidates, CompactionLifeCycleTracker tracker) Called prior to selecting theStoreFiles
to compact from the list of available candidates.default void
MasterObserver.preCreateNamespace
(ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor ns) Called before a new namespace is created byHMaster
.default void
MasterObserver.preCreateTable
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableDescriptor desc, RegionInfo[] regions) Called before a new table is created byHMaster
.default void
MasterObserver.preCreateTableAction
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableDescriptor desc, RegionInfo[] regions) Called before a new table is created byHMaster
.default TableDescriptor
MasterObserver.preCreateTableRegionsInfos
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableDescriptor desc) Called before we create the region infos for this table.default void
MasterObserver.preDecommissionRegionServers
(ObserverContext<MasterCoprocessorEnvironment> ctx, List<ServerName> servers, boolean offload) Called before decommission region servers.void
MetaTableMetrics.ExampleRegionObserverMeta.preDelete
(ObserverContext<? extends RegionCoprocessorEnvironment> e, Delete delete, WALEdit edit, Durability durability) default void
RegionObserver.preDelete
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Delete delete, WALEdit edit) Called before the client deletes a value.default void
RegionObserver.preDelete
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Delete delete, WALEdit edit, Durability durability) Deprecated.since 3.0.0 and will be removed in 4.0.0.default void
MasterObserver.preDeleteNamespace
(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace) Called beforeHMaster
deletes a namespacedefault void
MasterObserver.preDeleteSnapshot
(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot) Called before a snapshot is deleted.default void
MasterObserver.preDeleteTable
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called beforeHMaster
deletes a table.default void
MasterObserver.preDeleteTableAction
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called beforeHMaster
deletes a table.default void
MasterObserver.preDisableReplicationPeer
(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId) Called before disable a replication peerdefault void
MasterObserver.preDisableTable
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called prior to disabling a table.default void
MasterObserver.preDisableTableAction
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called prior to disabling a table.default void
MasterObserver.preEnableReplicationPeer
(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId) Called before enable a replication peerdefault void
MasterObserver.preEnableTable
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called prior to enabling a table.default void
MasterObserver.preEnableTableAction
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called prior to enabling a table.default org.apache.hbase.thirdparty.com.google.protobuf.Message
EndpointObserver.preEndpointInvocation
(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, org.apache.hbase.thirdparty.com.google.protobuf.Service service, String methodName, org.apache.hbase.thirdparty.com.google.protobuf.Message request) Called before an Endpoint service method is invoked.default void
RegionServerObserver.preExecuteProcedures
(ObserverContext<RegionServerCoprocessorEnvironment> ctx) This will be called before executing proceduresdefault boolean
RegionObserver.preExists
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Get get, boolean exists) Called before the client tests for existence using a Get.default void
RegionObserver.preFlush
(ObserverContext<? extends RegionCoprocessorEnvironment> c, FlushLifeCycleTracker tracker) Called before the memstore is flushed to disk.default InternalScanner
RegionObserver.preFlush
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, FlushLifeCycleTracker tracker) Called before a Store's memstore is flushed to disk.default void
RegionObserver.preFlushScannerOpen
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Store store, ScanOptions options, FlushLifeCycleTracker tracker) Called before we open store scanner for flush.default void
MasterObserver.preGetClusterMetrics
(ObserverContext<MasterCoprocessorEnvironment> ctx) Called before get cluster status.default void
MasterObserver.preGetConfiguredNamespacesAndTablesInRSGroup
(ObserverContext<MasterCoprocessorEnvironment> ctx, String groupName) Called before getting the configured namespaces and tables in the region server group.default void
MasterObserver.preGetLocks
(ObserverContext<MasterCoprocessorEnvironment> ctx) Called before a getLocks request has been processed.default void
MasterObserver.preGetNamespaceDescriptor
(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace) Called before a getNamespaceDescriptor request has been processed.void
MetaTableMetrics.ExampleRegionObserverMeta.preGetOp
(ObserverContext<? extends RegionCoprocessorEnvironment> e, Get get, List<Cell> results) default void
RegionObserver.preGetOp
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Get get, List<Cell> result) Called before the client performs a Getdefault void
MasterObserver.preGetProcedures
(ObserverContext<MasterCoprocessorEnvironment> ctx) Called before a getProcedures request has been processed.default void
MasterObserver.preGetReplicationPeerConfig
(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId) Called before get the configured ReplicationPeerConfig for the specified peerdefault void
MasterObserver.preGetRSGroupInfo
(ObserverContext<MasterCoprocessorEnvironment> ctx, String groupName) Called before getting region server group info of the passed groupName.default void
MasterObserver.preGetRSGroupInfoOfServer
(ObserverContext<MasterCoprocessorEnvironment> ctx, Address server) Called before getting region server group info of the passed server.default void
MasterObserver.preGetRSGroupInfoOfTable
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called before getting region server group info of the passed tableName.default void
MasterObserver.preGetTableDescriptors
(ObserverContext<MasterCoprocessorEnvironment> ctx, List<TableName> tableNamesList, List<TableDescriptor> descriptors, String regex) Called before a getTableDescriptors request has been processed.default void
MasterObserver.preGetTableNames
(ObserverContext<MasterCoprocessorEnvironment> ctx, List<TableDescriptor> descriptors, String regex) Called before a getTableNames request has been processed.default void
MasterObserver.preGetUserPermissions
(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, String namespace, TableName tableName, byte[] family, byte[] qualifier) Called before getting user permissions.default void
MasterObserver.preGrant
(ObserverContext<MasterCoprocessorEnvironment> ctx, UserPermission userPermission, boolean mergeExistingPermissions) Called before granting user permissions.default void
MasterObserver.preHasUserPermissions
(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, List<Permission> permissions) default Result
RegionObserver.preIncrement
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Increment increment) Deprecated.since 3.0.0 and will be removed in 4.0.0.default Result
RegionObserver.preIncrement
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Increment increment, WALEdit edit) Called before Increment.default Result
RegionObserver.preIncrementAfterRowLock
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Increment increment) Deprecated.since 3.0.0 and will be removed in 4.0.0.default void
MasterObserver.preIsRpcThrottleEnabled
(ObserverContext<MasterCoprocessorEnvironment> ctx) Called before getting if is rpc throttle enabled.default void
MasterObserver.preListDecommissionedRegionServers
(ObserverContext<MasterCoprocessorEnvironment> ctx) Called before list decommissioned region servers.default void
MasterObserver.preListNamespaceDescriptors
(ObserverContext<MasterCoprocessorEnvironment> ctx, List<NamespaceDescriptor> descriptors) Called before a listNamespaceDescriptors request has been processed.default void
MasterObserver.preListNamespaces
(ObserverContext<MasterCoprocessorEnvironment> ctx, List<String> namespaces) Called before a listNamespaces request has been processed.default void
MasterObserver.preListReplicationPeers
(ObserverContext<MasterCoprocessorEnvironment> ctx, String regex) Called before list replication peers.default void
MasterObserver.preListRSGroups
(ObserverContext<MasterCoprocessorEnvironment> ctx) Called before listing region server group information.default void
MasterObserver.preListSnapshot
(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot) Called before listSnapshots request has been processed.default void
MasterObserver.preListTablesInRSGroup
(ObserverContext<MasterCoprocessorEnvironment> ctx, String groupName) Called before listing all tables in the region server group.default void
MasterObserver.preLockHeartbeat
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tn, String description) Called before heartbeat to a lock.default void
MasterObserver.preMasterInitialization
(ObserverContext<MasterCoprocessorEnvironment> ctx) Call before the master initialization is set to true.default void
MasterObserver.preMasterStoreFlush
(ObserverContext<MasterCoprocessorEnvironment> ctx) Called before the master local region memstore is flushed to disk.default void
RegionObserver.preMemStoreCompaction
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Store store) Called before in memory compaction started.default InternalScanner
RegionObserver.preMemStoreCompactionCompact
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner) Called before we do in memory compaction.default void
RegionObserver.preMemStoreCompactionCompactScannerOpen
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Store store, ScanOptions options) Called before we open store scanner for in memory compaction.default void
MasterObserver.preMergeRegions
(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo[] regionsToMerge) Called before merge regions request.default void
MasterObserver.preMergeRegionsAction
(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo[] regionsToMerge) Called before the regions merge.default void
MasterObserver.preMergeRegionsCommitAction
(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo[] regionsToMerge, List<Mutation> metaEntries) This will be called before update META step as part of regions merge transaction.default String
MasterObserver.preModifyColumnFamilyStoreFileTracker
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, byte[] family, String dstSFT) Called prior to modifying a family's store file tracker.default void
MasterObserver.preModifyNamespace
(ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor currentNsDescriptor, NamespaceDescriptor newNsDescriptor) Called prior to modifying a namespace's properties.default TableDescriptor
MasterObserver.preModifyTable
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, TableDescriptor currentDescriptor, TableDescriptor newDescriptor) Called prior to modifying a table's properties.default void
MasterObserver.preModifyTableAction
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, TableDescriptor currentDescriptor, TableDescriptor newDescriptor) Called prior to modifying a table's properties.default String
MasterObserver.preModifyTableStoreFileTracker
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, String dstSFT) Called prior to modifying a table's store file tracker.default void
MasterObserver.preMove
(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo region, ServerName srcServer, ServerName destServer) Called prior to moving a given region from one region server to another.default void
MasterObserver.preMoveServers
(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<Address> servers, String targetGroup) Called before servers are moved to target region server groupdefault void
MasterObserver.preMoveServersAndTables
(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<Address> servers, Set<TableName> tables, String targetGroup) Called before servers are moved to target region server groupdefault void
MasterObserver.preMoveTables
(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<TableName> tables, String targetGroup) Called before tables are moved to target region server groupdefault void
RegionObserver.preOpen
(ObserverContext<? extends 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<? extends RegionCoprocessorEnvironment> c, Mutation mutation, Cell cell, byte[] byteNow, Get get) Deprecated.Since hbase-2.0.0.void
MetaTableMetrics.ExampleRegionObserverMeta.prePut
(ObserverContext<? extends RegionCoprocessorEnvironment> e, Put put, WALEdit edit, Durability durability) default void
RegionObserver.prePut
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Put put, WALEdit edit) Called before the client stores a value.default void
RegionObserver.prePut
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Put put, WALEdit edit, Durability durability) Deprecated.since 3.0.0 and will be removed in 4.0.0.default void
MasterObserver.preRecommissionRegionServer
(ObserverContext<MasterCoprocessorEnvironment> ctx, ServerName server, List<byte[]> encodedRegionNames) Called before recommission region server.default void
MasterObserver.preRegionOffline
(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo regionInfo) Called prior to marking a given region as offline.default void
MasterObserver.preRemoveReplicationPeer
(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId) Called before remove a replication peerdefault void
MasterObserver.preRemoveRSGroup
(ObserverContext<MasterCoprocessorEnvironment> ctx, String name) Called before a region server group is removeddefault void
MasterObserver.preRemoveServers
(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<Address> servers) Called before servers are removed from rsgroupdefault void
MasterObserver.preRenameRSGroup
(ObserverContext<MasterCoprocessorEnvironment> ctx, String oldName, String newName) Called before rename rsgroup.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
RegionServerObserver.preReplicateLogEntries
(ObserverContext<RegionServerCoprocessorEnvironment> ctx) Deprecated.As of release 2.0.0 with out any replacement, plan to remove in 4.0.0.default void
RegionServerObserver.preReplicationSinkBatchMutate
(ObserverContext<RegionServerCoprocessorEnvironment> ctx, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WALEntry walEntry, Mutation mutation) This will be called before replication sink mutations are executed on the sink table as part of batch call.default void
MasterObserver.preRequestLock
(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace, TableName tableName, RegionInfo[] regionInfos, String description) Called before new LockProcedure is queued.default void
MasterObserver.preRestoreSnapshot
(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot, TableDescriptor tableDescriptor) Called before a snapshot is restored.default void
MasterObserver.preRevoke
(ObserverContext<MasterCoprocessorEnvironment> ctx, UserPermission userPermission) Called before revoking user permissions.default void
RegionServerObserver.preRollWALWriterRequest
(ObserverContext<RegionServerCoprocessorEnvironment> ctx) This will be called before executing user request to roll a region server WAL.default void
RegionObserver.preScannerClose
(ObserverContext<? extends RegionCoprocessorEnvironment> c, InternalScanner s) Called before the client closes a scanner.default boolean
RegionObserver.preScannerNext
(ObserverContext<? extends 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<? extends RegionCoprocessorEnvironment> c, Scan scan) Called before the client opens a new scanner.default void
MasterObserver.preSetNamespaceQuota
(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace, GlobalQuotaSettings quotas) Called before the quota for the namespace is stored.default void
MasterObserver.preSetRegionServerQuota
(ObserverContext<MasterCoprocessorEnvironment> ctx, String regionServer, GlobalQuotaSettings quotas) Called before the quota for the region server is stored.default void
MasterObserver.preSetSplitOrMergeEnabled
(ObserverContext<MasterCoprocessorEnvironment> ctx, boolean newValue, MasterSwitchType switchType) Called prior to setting split / merge switch Supports Coprocessor 'bypass'.default void
MasterObserver.preSetTableQuota
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, GlobalQuotaSettings quotas) Called before the quota for the table is stored.default void
MasterObserver.preSetUserQuota
(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, String namespace, GlobalQuotaSettings quotas) Called before the quota for the user on the specified namespace is stored.default void
MasterObserver.preSetUserQuota
(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, GlobalQuotaSettings quotas) Called before the quota for the user is stored.default void
MasterObserver.preSetUserQuota
(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, TableName tableName, GlobalQuotaSettings quotas) Called before the quota for the user on the specified table is stored.default void
MasterObserver.preShutdown
(ObserverContext<MasterCoprocessorEnvironment> ctx) Called prior to shutting down the full HBase cluster, including thisHMaster
process.default void
MasterObserver.preSnapshot
(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot, TableDescriptor tableDescriptor) Called before a new snapshot is taken.default void
MasterObserver.preSplitRegion
(ObserverContext<MasterCoprocessorEnvironment> c, TableName tableName, byte[] splitRow) Called before the split region procedure is called.default void
MasterObserver.preSplitRegionAction
(ObserverContext<MasterCoprocessorEnvironment> c, TableName tableName, byte[] splitRow) Called before the region is split.default void
MasterObserver.preSplitRegionAfterMETAAction
(ObserverContext<MasterCoprocessorEnvironment> ctx) This will be called after update META step as part of split transactiondefault void
MasterObserver.preSplitRegionBeforeMETAAction
(ObserverContext<MasterCoprocessorEnvironment> ctx, byte[] splitKey, List<Mutation> metaEntries) This will be called before update META step as part of split transaction.default void
MasterObserver.preStopMaster
(ObserverContext<MasterCoprocessorEnvironment> ctx) Called immediately prior to stopping thisHMaster
process.default void
RegionServerObserver.preStopRegionServer
(ObserverContext<RegionServerCoprocessorEnvironment> ctx) Called before stopping region server.default StoreFileReader
RegionObserver.preStoreFileReaderOpen
(ObserverContext<? extends 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<? extends RegionCoprocessorEnvironment> ctx, Store store, ScanOptions options) Called before a store opens a new scanner.default void
MasterObserver.preSwitchExceedThrottleQuota
(ObserverContext<MasterCoprocessorEnvironment> ctx, boolean enable) Called before switching exceed throttle quota state.default void
MasterObserver.preSwitchRpcThrottle
(ObserverContext<MasterCoprocessorEnvironment> ctx, boolean enable) Called before switching rpc throttle enabled state.default void
MasterObserver.preTableFlush
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called before the table memstore is flushed to disk.default void
MasterObserver.preTransitReplicationPeerSyncReplicationState
(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId, SyncReplicationState state) Called before transit current cluster state for the specified synchronous replication peerdefault void
MasterObserver.preTruncateRegion
(ObserverContext<MasterCoprocessorEnvironment> c, RegionInfo regionInfo) Called before the truncate region procedure is called.default void
MasterObserver.preTruncateRegionAction
(ObserverContext<MasterCoprocessorEnvironment> c, RegionInfo regionInfo) Called before the region is truncated.default void
MasterObserver.preTruncateTable
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called beforeHMaster
truncates a table.default void
MasterObserver.preTruncateTableAction
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called beforeHMaster
truncates a table.default void
MasterObserver.preUnassign
(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo regionInfo) Called prior to unassigning a given region.default void
MasterObserver.preUpdateMasterConfiguration
(ObserverContext<MasterCoprocessorEnvironment> ctx, org.apache.hadoop.conf.Configuration preReloadConf) Called before reloading the HMaster'sConfiguration
from diskdefault void
RegionServerObserver.preUpdateRegionServerConfiguration
(ObserverContext<RegionServerCoprocessorEnvironment> ctx, org.apache.hadoop.conf.Configuration preReloadConf) Called before reloading the RegionServer'sConfiguration
from diskdefault void
MasterObserver.preUpdateReplicationPeerConfig
(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId, ReplicationPeerConfig peerConfig) Called before update peerConfig for the specified peerdefault void
MasterObserver.preUpdateRSGroupConfig
(ObserverContext<MasterCoprocessorEnvironment> ctx, String groupName, Map<String, String> configuration) Called before update rsgroup config.default void
RegionObserver.preWALAppend
(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, WALKey key, WALEdit edit) Called just before the WAL Entry is appended to the WAL.default void
WALObserver.preWALRoll
(ObserverContext<? extends WALCoprocessorEnvironment> ctx, org.apache.hadoop.fs.Path oldPath, org.apache.hadoop.fs.Path newPath) Called before rolling the current WALdefault void
WALObserver.preWALWrite
(ObserverContext<? extends WALCoprocessorEnvironment> ctx, RegionInfo info, WALKey logKey, WALEdit logEdit) Called before aWALEdit
is writen to WAL.private void
MetaTableMetrics.ExampleRegionObserverMeta.registerAndMarkMetrics
(ObserverContext<? extends RegionCoprocessorEnvironment> e, Row row) -
Uses of ObserverContext in org.apache.hadoop.hbase.coprocessor.example
Modifier and TypeMethodDescriptionvoid
ExampleRegionObserverWithMetrics.ExampleRegionObserver.postCompactSelection
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Store store, List<? extends StoreFile> selected, CompactionLifeCycleTracker tracker, CompactionRequest request) void
ExampleMasterObserverWithMetrics.postCreateTable
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableDescriptor desc, RegionInfo[] regions) void
ExampleRegionObserverWithMetrics.ExampleRegionObserver.postFlush
(ObserverContext<? extends RegionCoprocessorEnvironment> c, FlushLifeCycleTracker tracker) void
ExampleRegionObserverWithMetrics.ExampleRegionObserver.postFlush
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Store store, StoreFile resultFile, FlushLifeCycleTracker tracker) void
ExampleRegionObserverWithMetrics.ExampleRegionObserver.postGetOp
(ObserverContext<? extends RegionCoprocessorEnvironment> e, Get get, List<Cell> results) ValueRewritingObserver.preCompact
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request) WriteHeavyIncrementObserver.preCompact
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request) void
WriteHeavyIncrementObserver.preCompactScannerOpen
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Store store, ScanType scanType, ScanOptions options, CompactionLifeCycleTracker tracker, CompactionRequest request) void
ZooKeeperScanPolicyObserver.preCompactScannerOpen
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Store store, ScanType scanType, ScanOptions options, CompactionLifeCycleTracker tracker, CompactionRequest request) void
ExampleMasterObserverWithMetrics.preCreateTable
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableDescriptor desc, RegionInfo[] regions) void
ExampleMasterObserverWithMetrics.preDisableTable
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) WriteHeavyIncrementObserver.preFlush
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, FlushLifeCycleTracker tracker) void
WriteHeavyIncrementObserver.preFlushScannerOpen
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Store store, ScanOptions options, FlushLifeCycleTracker tracker) void
ZooKeeperScanPolicyObserver.preFlushScannerOpen
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Store store, ScanOptions options, FlushLifeCycleTracker tracker) void
ExampleRegionObserverWithMetrics.ExampleRegionObserver.preGetOp
(ObserverContext<? extends RegionCoprocessorEnvironment> e, Get get, List<Cell> results) void
WriteHeavyIncrementObserver.preGetOp
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Get get, List<Cell> result) WriteHeavyIncrementObserver.preIncrement
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Increment increment) WriteHeavyIncrementObserver.preMemStoreCompactionCompact
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner) void
WriteHeavyIncrementObserver.preMemStoreCompactionCompactScannerOpen
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Store store, ScanOptions options) void
ScanModifyingObserver.preScannerOpen
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Scan scan) void
WriteHeavyIncrementObserver.preStoreScannerOpen
(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, Store store, ScanOptions options) -
Uses of ObserverContext in org.apache.hadoop.hbase.master
Modifier and TypeClassDescription(package private) class
-
Uses of ObserverContext in org.apache.hadoop.hbase.quotas
Modifier and TypeMethodDescriptionvoid
MasterQuotasObserver.postDeleteNamespace
(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace) void
MasterQuotasObserver.postDeleteTable
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) -
Uses of ObserverContext in org.apache.hadoop.hbase.regionserver
Modifier and TypeClassDescription(package private) class
(package private) class
(package private) class
-
Uses of ObserverContext in org.apache.hadoop.hbase.regionserver.wal
-
Uses of ObserverContext in org.apache.hadoop.hbase.replication.regionserver
Modifier and TypeMethodDescriptionvoid
ReplicationObserver.preCommitStoreFile
(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, byte[] family, List<Pair<org.apache.hadoop.fs.Path, org.apache.hadoop.fs.Path>> pairs) -
Uses of ObserverContext in org.apache.hadoop.hbase.security.access
Modifier and TypeMethodDescriptionvoid
AccessController.checkLockPermissions
(ObserverContext<?> ctx, String namespace, TableName tableName, RegionInfo[] regionInfos, String reason) private User
AccessController.getActiveUser
(ObserverContext<?> ctx) Returns the active user to which authorization checks should be applied.private User
SnapshotScannerHDFSAclController.getActiveUser
(ObserverContext<?> ctx) private void
AccessController.internalPreRead
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Query query, AccessController.OpType opType) void
AccessController.postAbortProcedure
(ObserverContext<MasterCoprocessorEnvironment> ctx) AccessController.postAppendBeforeWAL
(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) void
AccessController.postCompletedCreateTableAction
(ObserverContext<MasterCoprocessorEnvironment> c, TableDescriptor desc, RegionInfo[] regions) void
SnapshotScannerHDFSAclController.postCompletedCreateTableAction
(ObserverContext<MasterCoprocessorEnvironment> c, TableDescriptor desc, RegionInfo[] regions) void
SnapshotScannerHDFSAclController.postCompletedDeleteTableAction
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) void
SnapshotScannerHDFSAclController.postCompletedSnapshotAction
(ObserverContext<MasterCoprocessorEnvironment> c, SnapshotDescription snapshot, TableDescriptor tableDescriptor) void
SnapshotScannerHDFSAclController.postCompletedTruncateTableAction
(ObserverContext<MasterCoprocessorEnvironment> c, TableName tableName) void
SnapshotScannerHDFSAclController.postCreateNamespace
(ObserverContext<MasterCoprocessorEnvironment> c, NamespaceDescriptor ns) AccessController.postCreateReplicationEndPoint
(ObserverContext<RegionServerCoprocessorEnvironment> ctx, ReplicationEndpoint endpoint) void
AccessController.postDelete
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Delete delete, WALEdit edit, Durability durability) void
AccessController.postDeleteNamespace
(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace) void
SnapshotScannerHDFSAclController.postDeleteNamespace
(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace) void
AccessController.postDeleteTable
(ObserverContext<MasterCoprocessorEnvironment> c, TableName tableName) void
AccessController.postEndpointInvocation
(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, org.apache.hbase.thirdparty.com.google.protobuf.Service service, String methodName, org.apache.hbase.thirdparty.com.google.protobuf.Message request, org.apache.hbase.thirdparty.com.google.protobuf.Message.Builder responseBuilder) void
AccessController.postGetTableDescriptors
(ObserverContext<MasterCoprocessorEnvironment> ctx, List<TableName> tableNamesList, List<TableDescriptor> descriptors, String regex) void
AccessController.postGetTableNames
(ObserverContext<MasterCoprocessorEnvironment> ctx, List<TableDescriptor> descriptors, String regex) void
SnapshotScannerHDFSAclController.postGrant
(ObserverContext<MasterCoprocessorEnvironment> c, UserPermission userPermission, boolean mergeExistingPermissions) AccessController.postIncrementBeforeWAL
(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) void
AccessController.postListNamespaceDescriptors
(ObserverContext<MasterCoprocessorEnvironment> ctx, List<NamespaceDescriptor> descriptors) void
AccessController.postListNamespaces
(ObserverContext<MasterCoprocessorEnvironment> ctx, List<String> namespaces) void
AccessController.postModifyTable
(ObserverContext<MasterCoprocessorEnvironment> c, TableName tableName, TableDescriptor oldDesc, TableDescriptor currentDesc) void
SnapshotScannerHDFSAclController.postModifyTable
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, TableDescriptor oldDescriptor, TableDescriptor currentDescriptor) void
AccessController.postOpen
(ObserverContext<? extends RegionCoprocessorEnvironment> c) void
AccessController.postPut
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Put put, WALEdit edit, Durability durability) void
SnapshotScannerHDFSAclController.postRevoke
(ObserverContext<MasterCoprocessorEnvironment> c, UserPermission userPermission) void
AccessController.postRollWALWriterRequest
(ObserverContext<RegionServerCoprocessorEnvironment> ctx) void
AccessController.postScannerClose
(ObserverContext<? extends RegionCoprocessorEnvironment> c, InternalScanner s) AccessController.postScannerOpen
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Scan scan, RegionScanner s) void
AccessController.postStartMaster
(ObserverContext<MasterCoprocessorEnvironment> ctx) void
SnapshotScannerHDFSAclController.postStartMaster
(ObserverContext<MasterCoprocessorEnvironment> c) void
AccessController.postTruncateTable
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) void
AccessController.preAbortProcedure
(ObserverContext<MasterCoprocessorEnvironment> ctx, long procId) void
AccessController.preAddReplicationPeer
(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId, ReplicationPeerConfig peerConfig) void
AccessController.preAddRSGroup
(ObserverContext<MasterCoprocessorEnvironment> ctx, String name) AccessController.preAppend
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Append append) void
AccessController.preAssign
(ObserverContext<MasterCoprocessorEnvironment> c, RegionInfo regionInfo) void
AccessController.preBalance
(ObserverContext<MasterCoprocessorEnvironment> c, BalanceRequest request) void
AccessController.preBalanceRSGroup
(ObserverContext<MasterCoprocessorEnvironment> ctx, String groupName, BalanceRequest request) void
AccessController.preBalanceSwitch
(ObserverContext<MasterCoprocessorEnvironment> c, boolean newValue) void
AccessController.preBatchMutate
(ObserverContext<? extends RegionCoprocessorEnvironment> c, MiniBatchOperationInProgress<Mutation> miniBatchOp) void
AccessController.preBulkLoadHFile
(ObserverContext<? extends 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<? extends RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Delete delete, boolean result) boolean
AccessController.preCheckAndDeleteAfterRowLock
(ObserverContext<? extends RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Delete delete, boolean result) boolean
AccessController.preCheckAndPut
(ObserverContext<? extends RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Put put, boolean result) boolean
AccessController.preCheckAndPutAfterRowLock
(ObserverContext<? extends 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.preClearCompactionQueues
(ObserverContext<RegionServerCoprocessorEnvironment> ctx) void
AccessController.preClearDeadServers
(ObserverContext<MasterCoprocessorEnvironment> ctx) void
AccessController.preClearRegionBlockCache
(ObserverContext<RegionServerCoprocessorEnvironment> ctx) void
AccessController.preCloneSnapshot
(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot, TableDescriptor hTableDescriptor) void
AccessController.preClose
(ObserverContext<? extends RegionCoprocessorEnvironment> c, boolean abortRequested) AccessController.preCompact
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request) void
AccessController.preCreateNamespace
(ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor ns) void
AccessController.preCreateTable
(ObserverContext<MasterCoprocessorEnvironment> c, TableDescriptor desc, RegionInfo[] regions) Observer implementationsvoid
CoprocessorWhitelistMasterObserver.preCreateTable
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableDescriptor htd, RegionInfo[] regions) void
AccessController.preDecommissionRegionServers
(ObserverContext<MasterCoprocessorEnvironment> ctx, List<ServerName> servers, boolean offload) void
AccessController.preDelete
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Delete delete, WALEdit edit, Durability durability) void
AccessController.preDeleteNamespace
(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace) void
AccessController.preDeleteSnapshot
(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot) void
AccessController.preDeleteTable
(ObserverContext<MasterCoprocessorEnvironment> c, TableName tableName) void
AccessController.preDisableReplicationPeer
(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId) void
AccessController.preDisableTable
(ObserverContext<MasterCoprocessorEnvironment> c, TableName tableName) void
AccessController.preEnableReplicationPeer
(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId) void
AccessController.preEnableTable
(ObserverContext<MasterCoprocessorEnvironment> c, TableName tableName) org.apache.hbase.thirdparty.com.google.protobuf.Message
AccessController.preEndpointInvocation
(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, org.apache.hbase.thirdparty.com.google.protobuf.Service service, String methodName, org.apache.hbase.thirdparty.com.google.protobuf.Message request) void
AccessController.preExecuteProcedures
(ObserverContext<RegionServerCoprocessorEnvironment> ctx) boolean
AccessController.preExists
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Get get, boolean exists) void
AccessController.preFlush
(ObserverContext<? extends RegionCoprocessorEnvironment> c, FlushLifeCycleTracker tracker) void
AccessController.preGetConfiguredNamespacesAndTablesInRSGroup
(ObserverContext<MasterCoprocessorEnvironment> ctx, String groupName) void
AccessController.preGetLocks
(ObserverContext<MasterCoprocessorEnvironment> ctx) void
AccessController.preGetNamespaceDescriptor
(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace) void
AccessController.preGetOp
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Get get, List<Cell> result) void
AccessController.preGetProcedures
(ObserverContext<MasterCoprocessorEnvironment> ctx) void
AccessController.preGetReplicationPeerConfig
(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId) void
AccessController.preGetRSGroupInfo
(ObserverContext<MasterCoprocessorEnvironment> ctx, String groupName) void
AccessController.preGetRSGroupInfoOfServer
(ObserverContext<MasterCoprocessorEnvironment> ctx, Address server) void
AccessController.preGetRSGroupInfoOfTable
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) void
AccessController.preGetTableDescriptors
(ObserverContext<MasterCoprocessorEnvironment> ctx, List<TableName> tableNamesList, List<TableDescriptor> descriptors, String regex) void
AccessController.preGetUserPermissions
(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, String namespace, TableName tableName, byte[] family, byte[] qualifier) void
AccessController.preGrant
(ObserverContext<MasterCoprocessorEnvironment> ctx, UserPermission userPermission, boolean mergeExistingPermissions) void
AccessController.preHasUserPermissions
(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, List<Permission> permissions) AccessController.preIncrement
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Increment increment) void
AccessController.preIsRpcThrottleEnabled
(ObserverContext<MasterCoprocessorEnvironment> ctx) void
AccessController.preListDecommissionedRegionServers
(ObserverContext<MasterCoprocessorEnvironment> ctx) void
AccessController.preListReplicationPeers
(ObserverContext<MasterCoprocessorEnvironment> ctx, String regex) void
AccessController.preListRSGroups
(ObserverContext<MasterCoprocessorEnvironment> ctx) void
AccessController.preListSnapshot
(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot) void
AccessController.preListTablesInRSGroup
(ObserverContext<MasterCoprocessorEnvironment> ctx, String groupName) void
AccessController.preLockHeartbeat
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, String description) void
SnapshotScannerHDFSAclController.preMasterInitialization
(ObserverContext<MasterCoprocessorEnvironment> c) void
AccessController.preMergeRegions
(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo[] regionsToMerge) AccessController.preModifyColumnFamilyStoreFileTracker
(ObserverContext<MasterCoprocessorEnvironment> c, TableName tableName, byte[] family, String dstSFT) void
AccessController.preModifyNamespace
(ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor currentNsDesc, NamespaceDescriptor newNsDesc) AccessController.preModifyTable
(ObserverContext<MasterCoprocessorEnvironment> c, TableName tableName, TableDescriptor currentDesc, TableDescriptor newDesc) CoprocessorWhitelistMasterObserver.preModifyTable
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, TableDescriptor currentDesc, TableDescriptor newDesc) AccessController.preModifyTableStoreFileTracker
(ObserverContext<MasterCoprocessorEnvironment> c, TableName tableName, String dstSFT) void
AccessController.preMove
(ObserverContext<MasterCoprocessorEnvironment> c, RegionInfo region, ServerName srcServer, ServerName destServer) void
AccessController.preMoveServers
(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<Address> servers, String targetGroup) void
AccessController.preMoveServersAndTables
(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<Address> servers, Set<TableName> tables, String targetGroup) void
AccessController.preMoveTables
(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<TableName> tables, String targetGroup) void
AccessController.preOpen
(ObserverContext<? extends RegionCoprocessorEnvironment> c) void
AccessController.prePrepareBulkLoad
(ObserverContext<RegionCoprocessorEnvironment> ctx) Authorization check for SecureBulkLoadProtocol.prepareBulkLoad()void
AccessController.prePut
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Put put, WALEdit edit, Durability durability) void
AccessController.preRecommissionRegionServer
(ObserverContext<MasterCoprocessorEnvironment> ctx, ServerName server, List<byte[]> encodedRegionNames) void
AccessController.preRegionOffline
(ObserverContext<MasterCoprocessorEnvironment> c, RegionInfo regionInfo) void
AccessController.preRemoveReplicationPeer
(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId) void
AccessController.preRemoveRSGroup
(ObserverContext<MasterCoprocessorEnvironment> ctx, String name) void
AccessController.preRemoveServers
(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<Address> servers) void
AccessController.preRenameRSGroup
(ObserverContext<MasterCoprocessorEnvironment> ctx, String oldName, String newName) void
AccessController.preReplicateLogEntries
(ObserverContext<RegionServerCoprocessorEnvironment> ctx) void
AccessController.preRequestLock
(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace, TableName tableName, RegionInfo[] regionInfos, String description) void
AccessController.preRestoreSnapshot
(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot, TableDescriptor hTableDescriptor) void
AccessController.preRevoke
(ObserverContext<MasterCoprocessorEnvironment> ctx, UserPermission userPermission) void
AccessController.preRollWALWriterRequest
(ObserverContext<RegionServerCoprocessorEnvironment> ctx) void
AccessController.preScannerClose
(ObserverContext<? extends RegionCoprocessorEnvironment> c, InternalScanner s) boolean
AccessController.preScannerNext
(ObserverContext<? extends RegionCoprocessorEnvironment> c, InternalScanner s, List<Result> result, int limit, boolean hasNext) void
AccessController.preScannerOpen
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Scan scan) void
AccessController.preSetNamespaceQuota
(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace, GlobalQuotaSettings quotas) void
AccessController.preSetRegionServerQuota
(ObserverContext<MasterCoprocessorEnvironment> ctx, String regionServer, GlobalQuotaSettings quotas) void
AccessController.preSetSplitOrMergeEnabled
(ObserverContext<MasterCoprocessorEnvironment> ctx, boolean newValue, MasterSwitchType switchType) void
AccessController.preSetTableQuota
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, GlobalQuotaSettings quotas) void
AccessController.preSetUserQuota
(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, String namespace, GlobalQuotaSettings quotas) void
AccessController.preSetUserQuota
(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, GlobalQuotaSettings quotas) void
AccessController.preSetUserQuota
(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, TableName tableName, GlobalQuotaSettings quotas) void
AccessController.preShutdown
(ObserverContext<MasterCoprocessorEnvironment> c) void
AccessController.preSnapshot
(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot, TableDescriptor hTableDescriptor) void
AccessController.preSplitRegion
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, byte[] splitRow) void
AccessController.preStopMaster
(ObserverContext<MasterCoprocessorEnvironment> c) void
SnapshotScannerHDFSAclController.preStopMaster
(ObserverContext<MasterCoprocessorEnvironment> c) void
AccessController.preStopRegionServer
(ObserverContext<RegionServerCoprocessorEnvironment> ctx) void
AccessController.preSwitchExceedThrottleQuota
(ObserverContext<MasterCoprocessorEnvironment> ctx, boolean enable) void
AccessController.preSwitchRpcThrottle
(ObserverContext<MasterCoprocessorEnvironment> ctx, boolean enable) void
AccessController.preTableFlush
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) void
AccessController.preTransitReplicationPeerSyncReplicationState
(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId, SyncReplicationState clusterState) void
AccessController.preTruncateTable
(ObserverContext<MasterCoprocessorEnvironment> c, TableName tableName) void
AccessController.preUnassign
(ObserverContext<MasterCoprocessorEnvironment> c, RegionInfo regionInfo) void
AccessController.preUpdateMasterConfiguration
(ObserverContext<MasterCoprocessorEnvironment> ctx, org.apache.hadoop.conf.Configuration preReloadConf) void
AccessController.preUpdateRegionServerConfiguration
(ObserverContext<RegionServerCoprocessorEnvironment> ctx, org.apache.hadoop.conf.Configuration preReloadConf) void
AccessController.preUpdateReplicationPeerConfig
(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId, ReplicationPeerConfig peerConfig) void
AccessController.preUpdateRSGroupConfig
(ObserverContext<MasterCoprocessorEnvironment> ctx, String groupName, Map<String, String> configuration) void
AccessController.requireAccess
(ObserverContext<?> ctx, String request, TableName tableName, Permission.Action... permissions) void
AccessController.requireGlobalPermission
(ObserverContext<?> ctx, String request, Permission.Action perm, String namespace) void
AccessController.requireGlobalPermission
(ObserverContext<?> ctx, String request, Permission.Action perm, TableName tableName, Map<byte[], ? extends Collection<byte[]>> familyMap) void
AccessController.requireNamespacePermission
(ObserverContext<?> ctx, String request, String namespace, Permission.Action... permissions) void
AccessController.requireNamespacePermission
(ObserverContext<?> ctx, String request, String namespace, TableName tableName, Map<byte[], ? extends Collection<byte[]>> familyMap, Permission.Action... permissions) void
AccessController.requirePermission
(ObserverContext<?> ctx, String request, Permission.Action perm) void
AccessController.requirePermission
(ObserverContext<?> ctx, String request, TableName tableName, byte[] family, byte[] qualifier, Permission.Action... permissions) void
AccessController.requireTablePermission
(ObserverContext<?> ctx, String request, TableName tableName, byte[] family, byte[] qualifier, Permission.Action... permissions) private static void
CoprocessorWhitelistMasterObserver.verifyCoprocessors
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableDescriptor htd) Perform the validation checks for a coprocessor to determine if the path is white listed or not. -
Uses of ObserverContext in org.apache.hadoop.hbase.security.visibility
Modifier and TypeMethodDescriptionVisibilityController.postAppendBeforeWAL
(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) VisibilityReplication.postCreateReplicationEndPoint
(ObserverContext<RegionServerCoprocessorEnvironment> ctx, ReplicationEndpoint endpoint) VisibilityController.postIncrementBeforeWAL
(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) VisibilityController.postInstantiateDeleteTracker
(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, DeleteTracker delTracker) void
VisibilityController.postOpen
(ObserverContext<? extends RegionCoprocessorEnvironment> e) Region related hooksvoid
VisibilityController.postScannerClose
(ObserverContext<? extends RegionCoprocessorEnvironment> c, InternalScanner s) VisibilityController.postScannerOpen
(ObserverContext<? extends RegionCoprocessorEnvironment> c, Scan scan, RegionScanner s) void
VisibilityController.postSetSplitOrMergeEnabled
(ObserverContext<MasterCoprocessorEnvironment> ctx, boolean newValue, MasterSwitchType switchType) void
VisibilityController.postStartMaster
(ObserverContext<MasterCoprocessorEnvironment> ctx) Master related hooksvoid
VisibilityController.preBatchMutate
(ObserverContext<? extends RegionCoprocessorEnvironment> c, MiniBatchOperationInProgress<Mutation> miniBatchOp) void
VisibilityController.preDisableTable
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) void
VisibilityController.preGetOp
(ObserverContext<? extends RegionCoprocessorEnvironment> e, Get get, List<Cell> results) VisibilityController.preModifyTable
(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, TableDescriptor currentDescriptor, TableDescriptor newDescriptor) void
VisibilityController.prePrepareTimeStampForDeleteVersion
(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, Mutation delete, Cell cell, byte[] byteNow, Get get) void
VisibilityController.preScannerClose
(ObserverContext<? extends RegionCoprocessorEnvironment> c, InternalScanner s) boolean
VisibilityController.preScannerNext
(ObserverContext<? extends RegionCoprocessorEnvironment> c, InternalScanner s, List<Result> result, int limit, boolean hasNext) void
VisibilityController.preScannerOpen
(ObserverContext<? extends RegionCoprocessorEnvironment> e, Scan scan) -
Uses of ObserverContext in org.apache.hadoop.hbase.tool
Modifier and TypeMethodDescriptionvoid
WriteSinkCoprocessor.preBatchMutate
(ObserverContext<? extends RegionCoprocessorEnvironment> c, MiniBatchOperationInProgress<Mutation> miniBatchOp) void
WriteSinkCoprocessor.preOpen
(ObserverContext<? extends RegionCoprocessorEnvironment> e)