Uses of Interface
org.apache.hadoop.hbase.coprocessor.ObserverContext
Packages that use 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
Methods in org.apache.hadoop.hbase.backup with parameters of type ObserverContextModifier and TypeMethodDescriptionvoidBackupObserver.postBulkLoadHFile(ObserverContext<RegionCoprocessorEnvironment> ctx, List<Pair<byte[], String>> stagingFamilyPaths, Map<byte[], List<org.apache.hadoop.fs.Path>> finalPaths) voidBackupObserver.preCommitStoreFile(ObserverContext<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
Methods in org.apache.hadoop.hbase.constraint with parameters of type ObserverContextModifier and TypeMethodDescriptionvoidConstraintProcessor.prePut(ObserverContext<RegionCoprocessorEnvironment> e, Put put, WALEdit edit, Durability durability) -
Uses of ObserverContext in org.apache.hadoop.hbase.coprocessor
Classes in org.apache.hadoop.hbase.coprocessor that implement ObserverContextModifier and TypeClassDescriptionprivate classclassclassclassObserverContextImpl<E extends CoprocessorEnvironment>This is the only implementation ofObserverContext, which serves as the interface for third-party Coprocessor developers.Methods in org.apache.hadoop.hbase.coprocessor that return ObserverContextModifier and TypeMethodDescriptionstatic <E extends CoprocessorEnvironment>
ObserverContext<E>ObserverContextImpl.createAndPrepare(E env) Deprecated.Methods in org.apache.hadoop.hbase.coprocessor with parameters of type ObserverContextModifier and TypeMethodDescriptionprivate booleanMetaTableMetrics.ExampleRegionObserverMeta.isMetaTableOp(ObserverContext<RegionCoprocessorEnvironment> e) default voidMasterObserver.postAbortProcedure(ObserverContext<MasterCoprocessorEnvironment> ctx) Called after a abortProcedure request has been processed.default voidMasterObserver.postAddReplicationPeer(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId, ReplicationPeerConfig peerConfig) Called after add a replication peerdefault voidMasterObserver.postAddRSGroup(ObserverContext<MasterCoprocessorEnvironment> ctx, String name) Called after a new region server group is addeddefault ResultRegionObserver.postAppend(ObserverContext<RegionCoprocessorEnvironment> c, Append append, Result result) Deprecated.since 2.5.0 and will be removed in 4.0.0.default ResultRegionObserver.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 voidMasterObserver.postAssign(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo regionInfo) Called after the region assignment has been requested.default voidMasterObserver.postBalance(ObserverContext<MasterCoprocessorEnvironment> ctx, BalanceRequest request, List<RegionPlan> plans) Called after the balancing plan has been submitted.default voidMasterObserver.postBalanceRSGroup(ObserverContext<MasterCoprocessorEnvironment> ctx, String groupName, BalanceRequest request, BalanceResponse response) Called after a region server group is removeddefault voidMasterObserver.postBalanceSwitch(ObserverContext<MasterCoprocessorEnvironment> ctx, boolean oldValue, boolean newValue) Called after the flag to enable/disable balancing has changed.default voidRegionObserver.postBatchMutate(ObserverContext<RegionCoprocessorEnvironment> c, MiniBatchOperationInProgress<Mutation> miniBatchOp) This will be called after applying a batch of Mutations on a region.default voidRegionObserver.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 voidRegionObserver.postBulkLoadHFile(ObserverContext<RegionCoprocessorEnvironment> ctx, List<Pair<byte[], String>> stagingFamilyPaths, Map<byte[], List<org.apache.hadoop.fs.Path>> finalPaths) Called after bulkLoadHFile.default booleanRegionObserver.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 booleanRegionObserver.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 CheckAndMutateResultRegionObserver.postCheckAndMutate(ObserverContext<RegionCoprocessorEnvironment> c, CheckAndMutate checkAndMutate, CheckAndMutateResult result) Called after checkAndMutatedefault booleanRegionObserver.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 booleanRegionObserver.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 voidRegionServerObserver.postClearCompactionQueues(ObserverContext<RegionServerCoprocessorEnvironment> ctx) This will be called after clearing compaction queuesdefault voidMasterObserver.postClearDeadServers(ObserverContext<MasterCoprocessorEnvironment> ctx, List<ServerName> servers, List<ServerName> notClearedServers) Called after clear dead region servers.default voidRegionServerObserver.postClearRegionBlockCache(ObserverContext<RegionServerCoprocessorEnvironment> ctx, CacheEvictionStats stats) Called after clearing the block caches for one or more regionsdefault voidMasterObserver.postCloneSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot, TableDescriptor tableDescriptor) Called after a snapshot clone operation has been requested.default voidRegionObserver.postClose(ObserverContext<RegionCoprocessorEnvironment> c, boolean abortRequested) Called after the region is reported as closed to the master.default voidRegionObserver.postCloseRegionOperation(ObserverContext<RegionCoprocessorEnvironment> ctx, Region.Operation operation) Called after releasing read lock inRegion.closeRegionOperation().default voidRegionObserver.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 voidRegionObserver.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 voidRegionObserver.postCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c, Store store, List<? extends StoreFile> selected, CompactionLifeCycleTracker tracker, CompactionRequest request) Called after theStoreFiles to compact have been selected from the available candidates.default voidMasterObserver.postCompletedCreateTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx, TableDescriptor desc, RegionInfo[] regions) Called after the createTable operation has been requested.default voidMasterObserver.postCompletedDeleteTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called afterHMasterdeletes a table.default voidMasterObserver.postCompletedDisableTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called after the disableTable operation has been requested.default voidMasterObserver.postCompletedEnableTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called after the enableTable operation has been requested.default voidMasterObserver.postCompletedMergeRegionsAction(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo[] regionsToMerge, RegionInfo mergedRegion) called after the regions merge.default voidMasterObserver.postCompletedModifyTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, TableDescriptor currentDescriptor) Deprecated.Since 2.1.default voidMasterObserver.postCompletedModifyTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, TableDescriptor oldDescriptor, TableDescriptor currentDescriptor) Called after to modifying a table's properties.default voidMasterObserver.postCompletedSnapshotAction(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot, TableDescriptor tableDescriptor) Called after the snapshot operation has been completed.default voidMasterObserver.postCompletedSplitRegionAction(ObserverContext<MasterCoprocessorEnvironment> c, RegionInfo regionInfoA, RegionInfo regionInfoB) Called after the region is split.default voidMasterObserver.postCompletedTruncateTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called afterHMastertruncates a table.default voidMasterObserver.postCreateNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor ns) Called after the createNamespace operation has been requested.default ReplicationEndpointRegionServerObserver.postCreateReplicationEndPoint(ObserverContext<RegionServerCoprocessorEnvironment> ctx, ReplicationEndpoint endpoint) This will be called after the replication endpoint is instantiated.default voidMasterObserver.postCreateTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableDescriptor desc, RegionInfo[] regions) Called after the createTable operation has been requested.default voidMasterObserver.postDecommissionRegionServers(ObserverContext<MasterCoprocessorEnvironment> ctx, List<ServerName> servers, boolean offload) Called after decommission region servers.default voidRegionObserver.postDelete(ObserverContext<RegionCoprocessorEnvironment> c, Delete delete, WALEdit edit) Called after the client deletes a value.default voidRegionObserver.postDelete(ObserverContext<RegionCoprocessorEnvironment> c, Delete delete, WALEdit edit, Durability durability) Deprecated.since 2.5.0 and will be removed in 4.0.0.default voidMasterObserver.postDeleteNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace) Called after the deleteNamespace operation has been requested.default voidMasterObserver.postDeleteSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot) Called after the delete snapshot operation has been requested.default voidMasterObserver.postDeleteTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called after the deleteTable operation has been requested.default voidMasterObserver.postDisableReplicationPeer(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId) Called after disable a replication peerdefault voidMasterObserver.postDisableTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called after the disableTable operation has been requested.default voidMasterObserver.postEnableReplicationPeer(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId) Called after enable a replication peerdefault voidMasterObserver.postEnableTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called after the enableTable operation has been requested.default voidEndpointObserver.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 voidRegionServerObserver.postExecuteProcedures(ObserverContext<RegionServerCoprocessorEnvironment> ctx) This will be called after executing proceduresdefault booleanRegionObserver.postExists(ObserverContext<RegionCoprocessorEnvironment> c, Get get, boolean exists) Called after the client tests for existence using a Get.default voidRegionObserver.postFlush(ObserverContext<RegionCoprocessorEnvironment> c, FlushLifeCycleTracker tracker) Called after the memstore is flushed to disk.default voidRegionObserver.postFlush(ObserverContext<RegionCoprocessorEnvironment> c, Store store, StoreFile resultFile, FlushLifeCycleTracker tracker) Called after a Store's memstore is flushed to disk.default voidMasterObserver.postGetClusterMetrics(ObserverContext<MasterCoprocessorEnvironment> ctx, ClusterMetrics status) Called after get cluster status.default voidMasterObserver.postGetLocks(ObserverContext<MasterCoprocessorEnvironment> ctx) Called after a getLocks request has been processed.default voidMasterObserver.postGetNamespaceDescriptor(ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor ns) Called after a getNamespaceDescriptor request has been processed.default voidRegionObserver.postGetOp(ObserverContext<RegionCoprocessorEnvironment> c, Get get, List<Cell> result) Called after the client performs a Getdefault voidMasterObserver.postGetProcedures(ObserverContext<MasterCoprocessorEnvironment> ctx) Called after a getProcedures request has been processed.default voidMasterObserver.postGetReplicationPeerConfig(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId) Called after get the configured ReplicationPeerConfig for the specified peerdefault voidMasterObserver.postGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx, List<TableName> tableNamesList, List<TableDescriptor> descriptors, String regex) Called after a getTableDescriptors request has been processed.default voidMasterObserver.postGetTableNames(ObserverContext<MasterCoprocessorEnvironment> ctx, List<TableDescriptor> descriptors, String regex) Called after a getTableNames request has been processed.default voidMasterObserver.postGetUserPermissions(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, String namespace, TableName tableName, byte[] family, byte[] qualifier) Called after getting user permissions.default voidMasterObserver.postGrant(ObserverContext<MasterCoprocessorEnvironment> ctx, UserPermission userPermission, boolean mergeExistingPermissions) Called after granting user permissions.default voidMasterObserver.postHasUserPermissions(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, List<Permission> permissions) Called after checking if user has permissions.default ResultRegionObserver.postIncrement(ObserverContext<RegionCoprocessorEnvironment> c, Increment increment, Result result) Deprecated.since 2.5.0 and will be removed in 4.0.0.default ResultRegionObserver.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 DeleteTrackerRegionObserver.postInstantiateDeleteTracker(ObserverContext<RegionCoprocessorEnvironment> ctx, DeleteTracker delTracker) Deprecated.Since 2.0 with out any replacement and will be removed in 3.0default voidMasterObserver.postIsRpcThrottleEnabled(ObserverContext<MasterCoprocessorEnvironment> ctx, boolean rpcThrottleEnabled) Called after getting if is rpc throttle enabled.default voidMasterObserver.postListDecommissionedRegionServers(ObserverContext<MasterCoprocessorEnvironment> ctx) Called after list decommissioned region servers.default voidMasterObserver.postListNamespaceDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx, List<NamespaceDescriptor> descriptors) Called after a listNamespaceDescriptors request has been processed.default voidMasterObserver.postListNamespaces(ObserverContext<MasterCoprocessorEnvironment> ctx, List<String> namespaces) Called after a listNamespaces request has been processed.default voidMasterObserver.postListReplicationPeers(ObserverContext<MasterCoprocessorEnvironment> ctx, String regex) Called after list replication peers.default voidMasterObserver.postListSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot) Called after listSnapshots request has been processed.default voidMasterObserver.postLockHeartbeat(ObserverContext<MasterCoprocessorEnvironment> ctx) Called after heartbeat to a lock.default voidMasterObserver.postMasterStoreFlush(ObserverContext<MasterCoprocessorEnvironment> ctx) Called after the master local region memstore is flushed to disk.default voidRegionObserver.postMemStoreCompaction(ObserverContext<RegionCoprocessorEnvironment> c, Store store) Called after the in memory compaction is finished.default voidMasterObserver.postMergeRegions(ObserverContext<MasterCoprocessorEnvironment> c, RegionInfo[] regionsToMerge) called after merge regions request.default voidMasterObserver.postMergeRegionsCommitAction(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo[] regionsToMerge, RegionInfo mergedRegion) This will be called after META step as part of regions merge transaction.default voidMasterObserver.postModifyColumnFamilyStoreFileTracker(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, byte[] family, String dstSFT) Called after modifying a family store file tracker.default voidMasterObserver.postModifyNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor currentNsDescriptor) Deprecated.Since 2.1.default voidMasterObserver.postModifyNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor oldNsDescriptor, NamespaceDescriptor currentNsDescriptor) Called after the modifyNamespace operation has been requested.default voidMasterObserver.postModifyTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, TableDescriptor currentDescriptor) Deprecated.Since 2.1.default voidMasterObserver.postModifyTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, TableDescriptor oldDescriptor, TableDescriptor currentDescriptor) Called after the modifyTable operation has been requested.default voidMasterObserver.postModifyTableStoreFileTracker(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, String dstSFT) Called after modifying a table's store file tracker.default voidMasterObserver.postMove(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo region, ServerName srcServer, ServerName destServer) Called after the region move has been requested.default voidMasterObserver.postMoveServers(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<Address> servers, String targetGroup) Called after servers are moved to target region server groupdefault voidMasterObserver.postMoveServersAndTables(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<Address> servers, Set<TableName> tables, String targetGroup) Called after servers are moved to target region server groupdefault voidMasterObserver.postMoveTables(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<TableName> tables, String targetGroup) Called after servers are moved to target region server groupdefault CellRegionObserver.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 voidRegionObserver.postOpen(ObserverContext<RegionCoprocessorEnvironment> c) Called after the region is reported as open to the master.default voidRegionObserver.postPut(ObserverContext<RegionCoprocessorEnvironment> c, Put put, WALEdit edit) Called after the client stores a value.default voidRegionObserver.postPut(ObserverContext<RegionCoprocessorEnvironment> c, Put put, WALEdit edit, Durability durability) Deprecated.since 2.5.0 and will be removed in 4.0.0.default voidMasterObserver.postRecommissionRegionServer(ObserverContext<MasterCoprocessorEnvironment> ctx, ServerName server, List<byte[]> encodedRegionNames) Called after recommission region server.default voidMasterObserver.postRegionOffline(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo regionInfo) Called after the region has been marked offline.default voidMasterObserver.postRemoveReplicationPeer(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId) Called after remove a replication peerdefault voidMasterObserver.postRemoveRSGroup(ObserverContext<MasterCoprocessorEnvironment> ctx, String name) Called after a region server group is removeddefault voidMasterObserver.postRemoveServers(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<Address> servers) Called after servers are removed from rsgroupdefault voidMasterObserver.postRenameRSGroup(ObserverContext<MasterCoprocessorEnvironment> ctx, String oldName, String newName) Called after rename rsgroup.default voidRegionObserver.postReplayWALs(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, RegionInfo info, org.apache.hadoop.fs.Path edits) Called after replaying WALs for this region.default voidRegionServerObserver.postReplicateLogEntries(ObserverContext<RegionServerCoprocessorEnvironment> ctx) Deprecated.As of release 2.0.0 with out any replacement.default voidRegionServerObserver.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 voidMasterObserver.postRequestLock(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace, TableName tableName, RegionInfo[] regionInfos, String description) Called after new LockProcedure is queued.default voidMasterObserver.postRestoreSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot, TableDescriptor tableDescriptor) Called after a snapshot restore operation has been requested.default voidMasterObserver.postRevoke(ObserverContext<MasterCoprocessorEnvironment> ctx, UserPermission userPermission) Called after revoking user permissions.default voidMasterObserver.postRollBackMergeRegionsAction(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo[] regionsToMerge) This will be called after the roll back of the regions merge.default voidMasterObserver.postRollBackSplitRegionAction(ObserverContext<MasterCoprocessorEnvironment> ctx) This will be called after the roll back of the split region is completeddefault voidRegionServerObserver.postRollWALWriterRequest(ObserverContext<RegionServerCoprocessorEnvironment> ctx) This will be called after executing user request to roll a region server WAL.default voidRegionObserver.postScannerClose(ObserverContext<RegionCoprocessorEnvironment> ctx, InternalScanner s) Called after the client closes a scanner.default booleanRegionObserver.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 booleanRegionObserver.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 RegionScannerRegionObserver.postScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Scan scan, RegionScanner s) Called after the client opens a new scanner.default voidMasterObserver.postSetNamespaceQuota(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace, GlobalQuotaSettings quotas) Called after the quota for the namespace is stored.default voidMasterObserver.postSetRegionServerQuota(ObserverContext<MasterCoprocessorEnvironment> ctx, String regionServer, GlobalQuotaSettings quotas) Called after the quota for the region server is stored.default voidMasterObserver.postSetSplitOrMergeEnabled(ObserverContext<MasterCoprocessorEnvironment> ctx, boolean newValue, MasterSwitchType switchType) Called after setting split / merge switchdefault voidMasterObserver.postSetTableQuota(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, GlobalQuotaSettings quotas) Called after the quota for the table is stored.default voidMasterObserver.postSetUserQuota(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, String namespace, GlobalQuotaSettings quotas) Called after the quota for the user on the specified namespace is stored.default voidMasterObserver.postSetUserQuota(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, GlobalQuotaSettings quotas) Called after the quota for the user is stored.default voidMasterObserver.postSetUserQuota(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, TableName tableName, GlobalQuotaSettings quotas) Called after the quota for the user on the specified table is stored.default voidMasterObserver.postSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot, TableDescriptor tableDescriptor) Called after the snapshot operation has been requested.default voidMasterObserver.postStartMaster(ObserverContext<MasterCoprocessorEnvironment> ctx) Called immediately after an active master instance has completed initialization.default voidRegionObserver.postStartRegionOperation(ObserverContext<RegionCoprocessorEnvironment> ctx, Region.Operation operation) This will be called for region operations where read lock is acquired inRegion.startRegionOperation().default StoreFileReaderRegionObserver.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 voidMasterObserver.postSwitchExceedThrottleQuota(ObserverContext<MasterCoprocessorEnvironment> ctx, boolean oldValue, boolean newValue) Called after switching exceed throttle quota state.default voidMasterObserver.postSwitchRpcThrottle(ObserverContext<MasterCoprocessorEnvironment> ctx, boolean oldValue, boolean newValue) Called after switching rpc throttle enabled state.default voidMasterObserver.postTableFlush(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called after the table memstore is flushed to disk.default voidMasterObserver.postTruncateRegion(ObserverContext<MasterCoprocessorEnvironment> c, RegionInfo regionInfo) Called after the truncate region procedure is called.default voidMasterObserver.postTruncateRegionAction(ObserverContext<MasterCoprocessorEnvironment> c, RegionInfo regionInfo) Called post the region is truncated.default voidMasterObserver.postTruncateTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called after the truncateTable operation has been requested.default voidMasterObserver.postUnassign(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo regionInfo) Called after the region unassignment has been requested.default voidMasterObserver.postUnassign(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo regionInfo, boolean force) Deprecated.in 2.4.0.default voidMasterObserver.postUpdateMasterConfiguration(ObserverContext<MasterCoprocessorEnvironment> ctx, org.apache.hadoop.conf.Configuration postReloadConf) Called after reloading the HMaster'sConfigurationfrom diskdefault voidRegionServerObserver.postUpdateRegionServerConfiguration(ObserverContext<RegionServerCoprocessorEnvironment> ctx, org.apache.hadoop.conf.Configuration postReloadConf) Called after reloading the RegionServer'sConfigurationfrom diskdefault voidMasterObserver.postUpdateReplicationPeerConfig(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId, ReplicationPeerConfig peerConfig) Called after update peerConfig for the specified peerdefault voidMasterObserver.postUpdateRSGroupConfig(ObserverContext<MasterCoprocessorEnvironment> ctx, String groupName, Map<String, String> configuration) Called after update rsgroup config.default voidRegionObserver.postWALRestore(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, RegionInfo info, WALKey logKey, WALEdit logEdit) Called after aWALEditreplayed for this region.default voidWALObserver.postWALRoll(ObserverContext<? extends WALCoprocessorEnvironment> ctx, org.apache.hadoop.fs.Path oldPath, org.apache.hadoop.fs.Path newPath) Called after rolling the current WALdefault voidWALObserver.postWALWrite(ObserverContext<? extends WALCoprocessorEnvironment> ctx, RegionInfo info, WALKey logKey, WALEdit logEdit) Deprecated.Since hbase-2.0.0.default voidMasterObserver.preAbortProcedure(ObserverContext<MasterCoprocessorEnvironment> ctx, long procId) Called before a abortProcedure request has been processed.default voidMasterObserver.preAddReplicationPeer(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId, ReplicationPeerConfig peerConfig) Called before add a replication peerdefault voidMasterObserver.preAddRSGroup(ObserverContext<MasterCoprocessorEnvironment> ctx, String name) Called before a new region server group is addeddefault ResultRegionObserver.preAppend(ObserverContext<RegionCoprocessorEnvironment> c, Append append) Deprecated.since 2.5.0 and will be removed in 4.0.0.default ResultRegionObserver.preAppend(ObserverContext<RegionCoprocessorEnvironment> c, Append append, WALEdit edit) Called before Append.default ResultRegionObserver.preAppendAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c, Append append) Deprecated.since 2.5.0 and will be removed in 4.0.0.default voidMasterObserver.preAssign(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo regionInfo) Called prior to assigning a specific region.default voidMasterObserver.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 voidMasterObserver.preBalanceRSGroup(ObserverContext<MasterCoprocessorEnvironment> ctx, String groupName, BalanceRequest request) Called before a region server group is removeddefault voidMasterObserver.preBalanceSwitch(ObserverContext<MasterCoprocessorEnvironment> ctx, boolean newValue) Called prior to modifying the flag used to enable/disable region balancing.default voidRegionObserver.preBatchMutate(ObserverContext<RegionCoprocessorEnvironment> c, MiniBatchOperationInProgress<Mutation> miniBatchOp) This will be called for every batch mutation operation happening at the server.default voidRegionObserver.preBulkLoadHFile(ObserverContext<RegionCoprocessorEnvironment> ctx, List<Pair<byte[], String>> familyPaths) Called before bulkLoadHFile.default booleanRegionObserver.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 booleanRegionObserver.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 booleanRegionObserver.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 booleanRegionObserver.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 CheckAndMutateResultRegionObserver.preCheckAndMutate(ObserverContext<RegionCoprocessorEnvironment> c, CheckAndMutate checkAndMutate, CheckAndMutateResult result) Called before checkAndMutatedefault CheckAndMutateResultRegionObserver.preCheckAndMutateAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c, CheckAndMutate checkAndMutate, CheckAndMutateResult result) Called before checkAndDelete but after acquiring rowlock.default booleanRegionObserver.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 booleanRegionObserver.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 booleanRegionObserver.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 booleanRegionObserver.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 voidBulkLoadObserver.preCleanupBulkLoad(ObserverContext<RegionCoprocessorEnvironment> ctx) Called as part of SecureBulkLoadEndpoint.cleanupBulkLoad() RPC call.default voidRegionServerObserver.preClearCompactionQueues(ObserverContext<RegionServerCoprocessorEnvironment> ctx) This will be called before clearing compaction queuesdefault voidMasterObserver.preClearDeadServers(ObserverContext<MasterCoprocessorEnvironment> ctx) Called before clear dead region servers.default voidRegionServerObserver.preClearRegionBlockCache(ObserverContext<RegionServerCoprocessorEnvironment> ctx) default voidMasterObserver.preCloneSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot, TableDescriptor tableDescriptor) Called before a snapshot is cloned.default voidRegionObserver.preClose(ObserverContext<RegionCoprocessorEnvironment> c, boolean abortRequested) Called before the region is reported as closed to the master.default voidRegionObserver.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 InternalScannerRegionObserver.preCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request) Called prior to writing theStoreFiles selected for compaction into a newStoreFile.default voidRegionObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store, ScanType scanType, ScanOptions options, CompactionLifeCycleTracker tracker, CompactionRequest request) Called before we open store scanner for compaction.default voidRegionObserver.preCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c, Store store, List<? extends StoreFile> candidates, CompactionLifeCycleTracker tracker) Called prior to selecting theStoreFilesto compact from the list of available candidates.default voidMasterObserver.preCreateNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor ns) Called before a new namespace is created byHMaster.default voidMasterObserver.preCreateTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableDescriptor desc, RegionInfo[] regions) Called before a new table is created byHMaster.default voidMasterObserver.preCreateTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx, TableDescriptor desc, RegionInfo[] regions) Called before a new table is created byHMaster.default TableDescriptorMasterObserver.preCreateTableRegionsInfos(ObserverContext<MasterCoprocessorEnvironment> ctx, TableDescriptor desc) Called before we create the region infos for this table.default voidMasterObserver.preDecommissionRegionServers(ObserverContext<MasterCoprocessorEnvironment> ctx, List<ServerName> servers, boolean offload) Called before decommission region servers.voidMetaTableMetrics.ExampleRegionObserverMeta.preDelete(ObserverContext<RegionCoprocessorEnvironment> e, Delete delete, WALEdit edit, Durability durability) default voidRegionObserver.preDelete(ObserverContext<RegionCoprocessorEnvironment> c, Delete delete, WALEdit edit) Called before the client deletes a value.default voidRegionObserver.preDelete(ObserverContext<RegionCoprocessorEnvironment> c, Delete delete, WALEdit edit, Durability durability) Deprecated.since 2.5.0 and will be removed in 4.0.0.default voidMasterObserver.preDeleteNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace) Called beforeHMasterdeletes a namespacedefault voidMasterObserver.preDeleteSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot) Called before a snapshot is deleted.default voidMasterObserver.preDeleteTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called beforeHMasterdeletes a table.default voidMasterObserver.preDeleteTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called beforeHMasterdeletes a table.default voidMasterObserver.preDisableReplicationPeer(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId) Called before disable a replication peerdefault voidMasterObserver.preDisableTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called prior to disabling a table.default voidMasterObserver.preDisableTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called prior to disabling a table.default voidMasterObserver.preEnableReplicationPeer(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId) Called before enable a replication peerdefault voidMasterObserver.preEnableTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called prior to enabling a table.default voidMasterObserver.preEnableTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called prior to enabling a table.default com.google.protobuf.MessageEndpointObserver.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 voidRegionServerObserver.preExecuteProcedures(ObserverContext<RegionServerCoprocessorEnvironment> ctx) This will be called before executing proceduresdefault booleanRegionObserver.preExists(ObserverContext<RegionCoprocessorEnvironment> c, Get get, boolean exists) Called before the client tests for existence using a Get.default voidRegionObserver.preFlush(ObserverContext<RegionCoprocessorEnvironment> c, FlushLifeCycleTracker tracker) Called before the memstore is flushed to disk.default InternalScannerRegionObserver.preFlush(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, FlushLifeCycleTracker tracker) Called before a Store's memstore is flushed to disk.default voidRegionObserver.preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store, ScanOptions options, FlushLifeCycleTracker tracker) Called before we open store scanner for flush.default voidMasterObserver.preGetClusterMetrics(ObserverContext<MasterCoprocessorEnvironment> ctx) Called before get cluster status.default voidMasterObserver.preGetLocks(ObserverContext<MasterCoprocessorEnvironment> ctx) Called before a getLocks request has been processed.default voidMasterObserver.preGetNamespaceDescriptor(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace) Called before a getNamespaceDescriptor request has been processed.voidMetaTableMetrics.ExampleRegionObserverMeta.preGetOp(ObserverContext<RegionCoprocessorEnvironment> e, Get get, List<Cell> results) default voidRegionObserver.preGetOp(ObserverContext<RegionCoprocessorEnvironment> c, Get get, List<Cell> result) Called before the client performs a Getdefault voidMasterObserver.preGetProcedures(ObserverContext<MasterCoprocessorEnvironment> ctx) Called before a getProcedures request has been processed.default voidMasterObserver.preGetReplicationPeerConfig(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId) Called before get the configured ReplicationPeerConfig for the specified peerdefault voidMasterObserver.preGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx, List<TableName> tableNamesList, List<TableDescriptor> descriptors, String regex) Called before a getTableDescriptors request has been processed.default voidMasterObserver.preGetTableNames(ObserverContext<MasterCoprocessorEnvironment> ctx, List<TableDescriptor> descriptors, String regex) Called before a getTableNames request has been processed.default voidMasterObserver.preGetUserPermissions(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, String namespace, TableName tableName, byte[] family, byte[] qualifier) Called before getting user permissions.default voidMasterObserver.preGrant(ObserverContext<MasterCoprocessorEnvironment> ctx, UserPermission userPermission, boolean mergeExistingPermissions) Called before granting user permissions.default voidMasterObserver.preHasUserPermissions(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, List<Permission> permissions) default ResultRegionObserver.preIncrement(ObserverContext<RegionCoprocessorEnvironment> c, Increment increment) Deprecated.since 2.5.0 and will be removed in 4.0.0.default ResultRegionObserver.preIncrement(ObserverContext<RegionCoprocessorEnvironment> c, Increment increment, WALEdit edit) Called before Increment.default ResultRegionObserver.preIncrementAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c, Increment increment) Deprecated.since 2.5.0 and will be removed in 4.0.0.default voidMasterObserver.preIsRpcThrottleEnabled(ObserverContext<MasterCoprocessorEnvironment> ctx) Called before getting if is rpc throttle enabled.default voidMasterObserver.preListDecommissionedRegionServers(ObserverContext<MasterCoprocessorEnvironment> ctx) Called before list decommissioned region servers.default voidMasterObserver.preListNamespaceDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx, List<NamespaceDescriptor> descriptors) Called before a listNamespaceDescriptors request has been processed.default voidMasterObserver.preListNamespaces(ObserverContext<MasterCoprocessorEnvironment> ctx, List<String> namespaces) Called before a listNamespaces request has been processed.default voidMasterObserver.preListReplicationPeers(ObserverContext<MasterCoprocessorEnvironment> ctx, String regex) Called before list replication peers.default voidMasterObserver.preListSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot) Called before listSnapshots request has been processed.default voidMasterObserver.preLockHeartbeat(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tn, String description) Called before heartbeat to a lock.default voidMasterObserver.preMasterInitialization(ObserverContext<MasterCoprocessorEnvironment> ctx) Call before the master initialization is set to true.default voidMasterObserver.preMasterStoreFlush(ObserverContext<MasterCoprocessorEnvironment> ctx) Called before the master local region memstore is flushed to disk.default voidRegionObserver.preMemStoreCompaction(ObserverContext<RegionCoprocessorEnvironment> c, Store store) Called before in memory compaction started.default InternalScannerRegionObserver.preMemStoreCompactionCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner) Called before we do in memory compaction.default voidRegionObserver.preMemStoreCompactionCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store, ScanOptions options) Called before we open store scanner for in memory compaction.default voidMasterObserver.preMergeRegions(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo[] regionsToMerge) Called before merge regions request.default voidMasterObserver.preMergeRegionsAction(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo[] regionsToMerge) Called before the regions merge.default voidMasterObserver.preMergeRegionsCommitAction(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo[] regionsToMerge, List<Mutation> metaEntries) This will be called before update META step as part of regions merge transaction.default StringMasterObserver.preModifyColumnFamilyStoreFileTracker(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, byte[] family, String dstSFT) Called prior to modifying a family's store file tracker.default voidMasterObserver.preModifyNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor newNsDescriptor) Deprecated.Since 2.1.default voidMasterObserver.preModifyNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor currentNsDescriptor, NamespaceDescriptor newNsDescriptor) Called prior to modifying a namespace's properties.default voidMasterObserver.preModifyTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, TableDescriptor newDescriptor) Deprecated.Since 2.1.default TableDescriptorMasterObserver.preModifyTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, TableDescriptor currentDescriptor, TableDescriptor newDescriptor) Called prior to modifying a table's properties.default voidMasterObserver.preModifyTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, TableDescriptor newDescriptor) Deprecated.Since 2.1.default voidMasterObserver.preModifyTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, TableDescriptor currentDescriptor, TableDescriptor newDescriptor) Called prior to modifying a table's properties.default StringMasterObserver.preModifyTableStoreFileTracker(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, String dstSFT) Called prior to modifying a table's store file tracker.default voidMasterObserver.preMove(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo region, ServerName srcServer, ServerName destServer) Called prior to moving a given region from one region server to another.default voidMasterObserver.preMoveServers(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<Address> servers, String targetGroup) Called before servers are moved to target region server groupdefault voidMasterObserver.preMoveServersAndTables(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<Address> servers, Set<TableName> tables, String targetGroup) Called before servers are moved to target region server groupdefault voidMasterObserver.preMoveTables(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<TableName> tables, String targetGroup) Called before tables are moved to target region server groupdefault voidRegionObserver.preOpen(ObserverContext<RegionCoprocessorEnvironment> c) Called before the region is reported as open to the master.default voidBulkLoadObserver.prePrepareBulkLoad(ObserverContext<RegionCoprocessorEnvironment> ctx) Called as part of SecureBulkLoadEndpoint.prepareBulkLoad() RPC call.default voidRegionObserver.prePrepareTimeStampForDeleteVersion(ObserverContext<RegionCoprocessorEnvironment> c, Mutation mutation, Cell cell, byte[] byteNow, Get get) Deprecated.Since hbase-2.0.0.voidMetaTableMetrics.ExampleRegionObserverMeta.prePut(ObserverContext<RegionCoprocessorEnvironment> e, Put put, WALEdit edit, Durability durability) default voidRegionObserver.prePut(ObserverContext<RegionCoprocessorEnvironment> c, Put put, WALEdit edit) Called before the client stores a value.default voidRegionObserver.prePut(ObserverContext<RegionCoprocessorEnvironment> c, Put put, WALEdit edit, Durability durability) Deprecated.since 2.5.0 and will be removed in 4.0.0.default voidMasterObserver.preRecommissionRegionServer(ObserverContext<MasterCoprocessorEnvironment> ctx, ServerName server, List<byte[]> encodedRegionNames) Called before recommission region server.default voidMasterObserver.preRegionOffline(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo regionInfo) Called prior to marking a given region as offline.default voidMasterObserver.preRemoveReplicationPeer(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId) Called before remove a replication peerdefault voidMasterObserver.preRemoveRSGroup(ObserverContext<MasterCoprocessorEnvironment> ctx, String name) Called before a region server group is removeddefault voidMasterObserver.preRemoveServers(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<Address> servers) Called before servers are removed from rsgroupdefault voidMasterObserver.preRenameRSGroup(ObserverContext<MasterCoprocessorEnvironment> ctx, String oldName, String newName) Called before rename rsgroup.default voidRegionObserver.preReplayWALs(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, RegionInfo info, org.apache.hadoop.fs.Path edits) Called before replaying WALs for this region.default voidRegionServerObserver.preReplicateLogEntries(ObserverContext<RegionServerCoprocessorEnvironment> ctx) Deprecated.As of release 2.0.0 with out any replacement.default voidRegionServerObserver.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 voidMasterObserver.preRequestLock(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace, TableName tableName, RegionInfo[] regionInfos, String description) Called before new LockProcedure is queued.default voidMasterObserver.preRestoreSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot, TableDescriptor tableDescriptor) Called before a snapshot is restored.default voidMasterObserver.preRevoke(ObserverContext<MasterCoprocessorEnvironment> ctx, UserPermission userPermission) Called before revoking user permissions.default voidRegionServerObserver.preRollWALWriterRequest(ObserverContext<RegionServerCoprocessorEnvironment> ctx) This will be called before executing user request to roll a region server WAL.default voidRegionObserver.preScannerClose(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s) Called before the client closes a scanner.default booleanRegionObserver.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 voidRegionObserver.preScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Scan scan) Called before the client opens a new scanner.default voidMasterObserver.preSetNamespaceQuota(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace, GlobalQuotaSettings quotas) Called before the quota for the namespace is stored.default voidMasterObserver.preSetRegionServerQuota(ObserverContext<MasterCoprocessorEnvironment> ctx, String regionServer, GlobalQuotaSettings quotas) Called before the quota for the region server is stored.default voidMasterObserver.preSetSplitOrMergeEnabled(ObserverContext<MasterCoprocessorEnvironment> ctx, boolean newValue, MasterSwitchType switchType) Called prior to setting split / merge switch Supports Coprocessor 'bypass'.default voidMasterObserver.preSetTableQuota(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, GlobalQuotaSettings quotas) Called before the quota for the table is stored.default voidMasterObserver.preSetUserQuota(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, String namespace, GlobalQuotaSettings quotas) Called before the quota for the user on the specified namespace is stored.default voidMasterObserver.preSetUserQuota(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, GlobalQuotaSettings quotas) Called before the quota for the user is stored.default voidMasterObserver.preSetUserQuota(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, TableName tableName, GlobalQuotaSettings quotas) Called before the quota for the user on the specified table is stored.default voidMasterObserver.preShutdown(ObserverContext<MasterCoprocessorEnvironment> ctx) Called prior to shutting down the full HBase cluster, including thisHMasterprocess.default voidMasterObserver.preSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot, TableDescriptor tableDescriptor) Called before a new snapshot is taken.default voidMasterObserver.preSplitRegion(ObserverContext<MasterCoprocessorEnvironment> c, TableName tableName, byte[] splitRow) Called before the split region procedure is called.default voidMasterObserver.preSplitRegionAction(ObserverContext<MasterCoprocessorEnvironment> c, TableName tableName, byte[] splitRow) Called before the region is split.default voidMasterObserver.preSplitRegionAfterMETAAction(ObserverContext<MasterCoprocessorEnvironment> ctx) This will be called after update META step as part of split transactiondefault voidMasterObserver.preSplitRegionBeforeMETAAction(ObserverContext<MasterCoprocessorEnvironment> ctx, byte[] splitKey, List<Mutation> metaEntries) This will be called before update META step as part of split transaction.default voidMasterObserver.preStopMaster(ObserverContext<MasterCoprocessorEnvironment> ctx) Called immediately prior to stopping thisHMasterprocess.default voidRegionServerObserver.preStopRegionServer(ObserverContext<RegionServerCoprocessorEnvironment> ctx) Called before stopping region server.default StoreFileReaderRegionObserver.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 voidRegionObserver.preStoreScannerOpen(ObserverContext<RegionCoprocessorEnvironment> ctx, Store store, ScanOptions options) Called before a store opens a new scanner.default voidMasterObserver.preSwitchExceedThrottleQuota(ObserverContext<MasterCoprocessorEnvironment> ctx, boolean enable) Called before switching exceed throttle quota state.default voidMasterObserver.preSwitchRpcThrottle(ObserverContext<MasterCoprocessorEnvironment> ctx, boolean enable) Called before switching rpc throttle enabled state.default voidMasterObserver.preTableFlush(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called before the table memstore is flushed to disk.default voidMasterObserver.preTruncateRegion(ObserverContext<MasterCoprocessorEnvironment> c, RegionInfo regionInfo) Called before the truncate region procedure is called.default voidMasterObserver.preTruncateRegionAction(ObserverContext<MasterCoprocessorEnvironment> c, RegionInfo regionInfo) Called before the region is truncated.default voidMasterObserver.preTruncateTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called beforeHMastertruncates a table.default voidMasterObserver.preTruncateTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called beforeHMastertruncates a table.default voidMasterObserver.preUnassign(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo regionInfo) Called prior to unassigning a given region.default voidMasterObserver.preUnassign(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo regionInfo, boolean force) Deprecated.in 2.4.0.default voidMasterObserver.preUpdateMasterConfiguration(ObserverContext<MasterCoprocessorEnvironment> ctx, org.apache.hadoop.conf.Configuration preReloadConf) default voidRegionServerObserver.preUpdateRegionServerConfiguration(ObserverContext<RegionServerCoprocessorEnvironment> ctx, org.apache.hadoop.conf.Configuration preReloadConf) Called before reloading the RegionServer'sConfigurationfrom diskdefault voidMasterObserver.preUpdateReplicationPeerConfig(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId, ReplicationPeerConfig peerConfig) Called before update peerConfig for the specified peerdefault voidMasterObserver.preUpdateRSGroupConfig(ObserverContext<MasterCoprocessorEnvironment> ctx, String groupName, Map<String, String> configuration) Called before update rsgroup config.default voidRegionObserver.preWALAppend(ObserverContext<RegionCoprocessorEnvironment> ctx, WALKey key, WALEdit edit) Called just before the WAL Entry is appended to the WAL.default voidRegionObserver.preWALRestore(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, RegionInfo info, WALKey logKey, WALEdit logEdit) Called before aWALEditreplayed for this region.default voidWALObserver.preWALRoll(ObserverContext<? extends WALCoprocessorEnvironment> ctx, org.apache.hadoop.fs.Path oldPath, org.apache.hadoop.fs.Path newPath) Called before rolling the current WALdefault voidWALObserver.preWALWrite(ObserverContext<? extends WALCoprocessorEnvironment> ctx, RegionInfo info, WALKey logKey, WALEdit logEdit) Deprecated.Since hbase-2.0.0.private voidMetaTableMetrics.ExampleRegionObserverMeta.registerAndMarkMetrics(ObserverContext<RegionCoprocessorEnvironment> e, Row row) -
Uses of ObserverContext in org.apache.hadoop.hbase.coprocessor.example
Methods in org.apache.hadoop.hbase.coprocessor.example with parameters of type ObserverContextModifier and TypeMethodDescriptionvoidExampleRegionObserverWithMetrics.ExampleRegionObserver.postCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c, Store store, List<? extends StoreFile> selected, CompactionLifeCycleTracker tracker, CompactionRequest request) voidExampleMasterObserverWithMetrics.postCreateTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableDescriptor desc, RegionInfo[] regions) voidExampleRegionObserverWithMetrics.ExampleRegionObserver.postFlush(ObserverContext<RegionCoprocessorEnvironment> c, FlushLifeCycleTracker tracker) voidExampleRegionObserverWithMetrics.ExampleRegionObserver.postFlush(ObserverContext<RegionCoprocessorEnvironment> c, Store store, StoreFile resultFile, FlushLifeCycleTracker tracker) voidExampleRegionObserverWithMetrics.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) voidWriteHeavyIncrementObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store, ScanType scanType, ScanOptions options, CompactionLifeCycleTracker tracker, CompactionRequest request) voidZooKeeperScanPolicyObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store, ScanType scanType, ScanOptions options, CompactionLifeCycleTracker tracker, CompactionRequest request) voidExampleMasterObserverWithMetrics.preCreateTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableDescriptor desc, RegionInfo[] regions) voidExampleMasterObserverWithMetrics.preDisableTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) WriteHeavyIncrementObserver.preFlush(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, FlushLifeCycleTracker tracker) voidWriteHeavyIncrementObserver.preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store, ScanOptions options, FlushLifeCycleTracker tracker) voidZooKeeperScanPolicyObserver.preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store, ScanOptions options, FlushLifeCycleTracker tracker) voidExampleRegionObserverWithMetrics.ExampleRegionObserver.preGetOp(ObserverContext<RegionCoprocessorEnvironment> e, Get get, List<Cell> results) voidWriteHeavyIncrementObserver.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) voidWriteHeavyIncrementObserver.preMemStoreCompactionCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store, ScanOptions options) voidScanModifyingObserver.preScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Scan scan) voidWriteHeavyIncrementObserver.preStoreScannerOpen(ObserverContext<RegionCoprocessorEnvironment> ctx, Store store, ScanOptions options) -
Uses of ObserverContext in org.apache.hadoop.hbase.master
Classes in org.apache.hadoop.hbase.master that implement ObserverContextModifier and TypeClassDescription(package private) class -
Uses of ObserverContext in org.apache.hadoop.hbase.quotas
Methods in org.apache.hadoop.hbase.quotas with parameters of type ObserverContextModifier and TypeMethodDescriptionvoidMasterQuotasObserver.postDeleteNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace) voidMasterQuotasObserver.postDeleteTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) -
Uses of ObserverContext in org.apache.hadoop.hbase.regionserver
Classes in org.apache.hadoop.hbase.regionserver that implement ObserverContextModifier and TypeClassDescription(package private) class(package private) class(package private) class -
Uses of ObserverContext in org.apache.hadoop.hbase.regionserver.wal
Classes in org.apache.hadoop.hbase.regionserver.wal that implement ObserverContext -
Uses of ObserverContext in org.apache.hadoop.hbase.replication.regionserver
Methods in org.apache.hadoop.hbase.replication.regionserver with parameters of type ObserverContextModifier and TypeMethodDescriptionvoidReplicationObserver.preCommitStoreFile(ObserverContext<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.rsgroup
Methods in org.apache.hadoop.hbase.rsgroup with parameters of type ObserverContextModifier and TypeMethodDescriptionvoidRSGroupAdminEndpoint.postClearDeadServers(ObserverContext<MasterCoprocessorEnvironment> ctx, List<ServerName> servers, List<ServerName> notClearedServers) voidRSGroupAdminEndpoint.postCompletedModifyTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, TableDescriptor oldDescriptor, TableDescriptor currentDescriptor) voidRSGroupAdminEndpoint.postDeleteTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) voidRSGroupAdminEndpoint.preCloneSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot, TableDescriptor desc) voidRSGroupAdminEndpoint.preCreateNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor ns) voidRSGroupAdminEndpoint.preCreateTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx, TableDescriptor desc, RegionInfo[] regions) voidRSGroupAdminEndpoint.preModifyNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor ns) voidRSGroupAdminEndpoint.preModifyTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, TableDescriptor currentDescriptor, TableDescriptor newDescriptor) -
Uses of ObserverContext in org.apache.hadoop.hbase.security.access
Methods in org.apache.hadoop.hbase.security.access with parameters of type ObserverContextModifier and TypeMethodDescriptionvoidAccessController.checkLockPermissions(ObserverContext<?> ctx, String namespace, TableName tableName, RegionInfo[] regionInfos, String reason) private UserAccessController.getActiveUser(ObserverContext<?> ctx) Returns the active user to which authorization checks should be applied.private UserSnapshotScannerHDFSAclController.getActiveUser(ObserverContext<?> ctx) private voidAccessController.internalPreRead(ObserverContext<RegionCoprocessorEnvironment> c, Query query, AccessController.OpType opType) voidAccessController.postAbortProcedure(ObserverContext<MasterCoprocessorEnvironment> ctx) AccessController.postAppendBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) voidAccessController.postCompletedCreateTableAction(ObserverContext<MasterCoprocessorEnvironment> c, TableDescriptor desc, RegionInfo[] regions) voidSnapshotScannerHDFSAclController.postCompletedCreateTableAction(ObserverContext<MasterCoprocessorEnvironment> c, TableDescriptor desc, RegionInfo[] regions) voidSnapshotScannerHDFSAclController.postCompletedDeleteTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) voidSnapshotScannerHDFSAclController.postCompletedSnapshotAction(ObserverContext<MasterCoprocessorEnvironment> c, SnapshotDescription snapshot, TableDescriptor tableDescriptor) voidSnapshotScannerHDFSAclController.postCompletedTruncateTableAction(ObserverContext<MasterCoprocessorEnvironment> c, TableName tableName) voidSnapshotScannerHDFSAclController.postCreateNamespace(ObserverContext<MasterCoprocessorEnvironment> c, NamespaceDescriptor ns) AccessController.postCreateReplicationEndPoint(ObserverContext<RegionServerCoprocessorEnvironment> ctx, ReplicationEndpoint endpoint) voidAccessController.postDelete(ObserverContext<RegionCoprocessorEnvironment> c, Delete delete, WALEdit edit, Durability durability) voidAccessController.postDeleteNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace) voidSnapshotScannerHDFSAclController.postDeleteNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace) voidAccessController.postDeleteTable(ObserverContext<MasterCoprocessorEnvironment> c, TableName tableName) voidAccessController.postEndpointInvocation(ObserverContext<RegionCoprocessorEnvironment> ctx, com.google.protobuf.Service service, String methodName, com.google.protobuf.Message request, com.google.protobuf.Message.Builder responseBuilder) voidAccessController.postGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx, List<TableName> tableNamesList, List<TableDescriptor> descriptors, String regex) voidAccessController.postGetTableNames(ObserverContext<MasterCoprocessorEnvironment> ctx, List<TableDescriptor> descriptors, String regex) voidSnapshotScannerHDFSAclController.postGrant(ObserverContext<MasterCoprocessorEnvironment> c, UserPermission userPermission, boolean mergeExistingPermissions) AccessController.postIncrementBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) voidAccessController.postListNamespaceDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx, List<NamespaceDescriptor> descriptors) voidAccessController.postListNamespaces(ObserverContext<MasterCoprocessorEnvironment> ctx, List<String> namespaces) voidAccessController.postModifyTable(ObserverContext<MasterCoprocessorEnvironment> c, TableName tableName, TableDescriptor htd) voidSnapshotScannerHDFSAclController.postModifyTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, TableDescriptor oldDescriptor, TableDescriptor currentDescriptor) voidAccessController.postOpen(ObserverContext<RegionCoprocessorEnvironment> c) voidAccessController.postPut(ObserverContext<RegionCoprocessorEnvironment> c, Put put, WALEdit edit, Durability durability) voidSnapshotScannerHDFSAclController.postRevoke(ObserverContext<MasterCoprocessorEnvironment> c, UserPermission userPermission) voidAccessController.postRollWALWriterRequest(ObserverContext<RegionServerCoprocessorEnvironment> ctx) voidAccessController.postScannerClose(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s) AccessController.postScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Scan scan, RegionScanner s) voidAccessController.postStartMaster(ObserverContext<MasterCoprocessorEnvironment> ctx) voidSnapshotScannerHDFSAclController.postStartMaster(ObserverContext<MasterCoprocessorEnvironment> c) voidAccessController.postTruncateTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) voidAccessController.preAbortProcedure(ObserverContext<MasterCoprocessorEnvironment> ctx, long procId) voidAccessController.preAddReplicationPeer(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId, ReplicationPeerConfig peerConfig) AccessController.preAppend(ObserverContext<RegionCoprocessorEnvironment> c, Append append) voidAccessController.preAssign(ObserverContext<MasterCoprocessorEnvironment> c, RegionInfo regionInfo) voidAccessController.preBalance(ObserverContext<MasterCoprocessorEnvironment> c, BalanceRequest request) voidAccessController.preBalanceSwitch(ObserverContext<MasterCoprocessorEnvironment> c, boolean newValue) voidAccessController.preBatchMutate(ObserverContext<RegionCoprocessorEnvironment> c, MiniBatchOperationInProgress<Mutation> miniBatchOp) voidAccessController.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.booleanAccessController.preCheckAndDelete(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Delete delete, boolean result) booleanAccessController.preCheckAndDeleteAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Delete delete, boolean result) booleanAccessController.preCheckAndPut(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Put put, boolean result) booleanAccessController.preCheckAndPutAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator opp, ByteArrayComparable comparator, Put put, boolean result) voidAccessController.preCleanupBulkLoad(ObserverContext<RegionCoprocessorEnvironment> ctx) Authorization security check for SecureBulkLoadProtocol.cleanupBulkLoad()voidAccessController.preClearCompactionQueues(ObserverContext<RegionServerCoprocessorEnvironment> ctx) voidAccessController.preClearDeadServers(ObserverContext<MasterCoprocessorEnvironment> ctx) voidAccessController.preClearRegionBlockCache(ObserverContext<RegionServerCoprocessorEnvironment> ctx) voidAccessController.preCloneSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot, TableDescriptor hTableDescriptor) voidAccessController.preClose(ObserverContext<RegionCoprocessorEnvironment> c, boolean abortRequested) AccessController.preCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request) voidAccessController.preCreateNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor ns) voidAccessController.preCreateTable(ObserverContext<MasterCoprocessorEnvironment> c, TableDescriptor desc, RegionInfo[] regions) Observer implementationsvoidCoprocessorWhitelistMasterObserver.preCreateTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableDescriptor htd, RegionInfo[] regions) voidAccessController.preDecommissionRegionServers(ObserverContext<MasterCoprocessorEnvironment> ctx, List<ServerName> servers, boolean offload) voidAccessController.preDelete(ObserverContext<RegionCoprocessorEnvironment> c, Delete delete, WALEdit edit, Durability durability) voidAccessController.preDeleteNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace) voidAccessController.preDeleteSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot) voidAccessController.preDeleteTable(ObserverContext<MasterCoprocessorEnvironment> c, TableName tableName) voidAccessController.preDisableReplicationPeer(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId) voidAccessController.preDisableTable(ObserverContext<MasterCoprocessorEnvironment> c, TableName tableName) voidAccessController.preEnableReplicationPeer(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId) voidAccessController.preEnableTable(ObserverContext<MasterCoprocessorEnvironment> c, TableName tableName) com.google.protobuf.MessageAccessController.preEndpointInvocation(ObserverContext<RegionCoprocessorEnvironment> ctx, com.google.protobuf.Service service, String methodName, com.google.protobuf.Message request) voidAccessController.preExecuteProcedures(ObserverContext<RegionServerCoprocessorEnvironment> ctx) booleanAccessController.preExists(ObserverContext<RegionCoprocessorEnvironment> c, Get get, boolean exists) voidAccessController.preFlush(ObserverContext<RegionCoprocessorEnvironment> c, FlushLifeCycleTracker tracker) voidAccessController.preGetLocks(ObserverContext<MasterCoprocessorEnvironment> ctx) voidAccessController.preGetNamespaceDescriptor(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace) voidAccessController.preGetOp(ObserverContext<RegionCoprocessorEnvironment> c, Get get, List<Cell> result) voidAccessController.preGetProcedures(ObserverContext<MasterCoprocessorEnvironment> ctx) voidAccessController.preGetReplicationPeerConfig(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId) voidAccessController.preGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx, List<TableName> tableNamesList, List<TableDescriptor> descriptors, String regex) voidAccessController.preGetUserPermissions(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, String namespace, TableName tableName, byte[] family, byte[] qualifier) voidAccessController.preGrant(ObserverContext<MasterCoprocessorEnvironment> ctx, UserPermission userPermission, boolean mergeExistingPermissions) voidAccessController.preHasUserPermissions(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, List<Permission> permissions) AccessController.preIncrement(ObserverContext<RegionCoprocessorEnvironment> c, Increment increment) voidAccessController.preIsRpcThrottleEnabled(ObserverContext<MasterCoprocessorEnvironment> ctx) voidAccessController.preListDecommissionedRegionServers(ObserverContext<MasterCoprocessorEnvironment> ctx) voidAccessController.preListReplicationPeers(ObserverContext<MasterCoprocessorEnvironment> ctx, String regex) voidAccessController.preListSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot) voidAccessController.preLockHeartbeat(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, String description) voidSnapshotScannerHDFSAclController.preMasterInitialization(ObserverContext<MasterCoprocessorEnvironment> c) voidAccessController.preMergeRegions(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo[] regionsToMerge) AccessController.preModifyColumnFamilyStoreFileTracker(ObserverContext<MasterCoprocessorEnvironment> c, TableName tableName, byte[] family, String dstSFT) voidAccessController.preModifyNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor ns) 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) voidAccessController.preMove(ObserverContext<MasterCoprocessorEnvironment> c, RegionInfo region, ServerName srcServer, ServerName destServer) voidAccessController.preOpen(ObserverContext<RegionCoprocessorEnvironment> c) voidAccessController.prePrepareBulkLoad(ObserverContext<RegionCoprocessorEnvironment> ctx) Authorization check for SecureBulkLoadProtocol.prepareBulkLoad()voidAccessController.prePut(ObserverContext<RegionCoprocessorEnvironment> c, Put put, WALEdit edit, Durability durability) voidAccessController.preRecommissionRegionServer(ObserverContext<MasterCoprocessorEnvironment> ctx, ServerName server, List<byte[]> encodedRegionNames) voidAccessController.preRegionOffline(ObserverContext<MasterCoprocessorEnvironment> c, RegionInfo regionInfo) voidAccessController.preRemoveReplicationPeer(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId) voidAccessController.preReplicateLogEntries(ObserverContext<RegionServerCoprocessorEnvironment> ctx) voidAccessController.preRequestLock(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace, TableName tableName, RegionInfo[] regionInfos, String description) voidAccessController.preRestoreSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot, TableDescriptor hTableDescriptor) voidAccessController.preRevoke(ObserverContext<MasterCoprocessorEnvironment> ctx, UserPermission userPermission) voidAccessController.preRollWALWriterRequest(ObserverContext<RegionServerCoprocessorEnvironment> ctx) voidAccessController.preScannerClose(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s) booleanAccessController.preScannerNext(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s, List<Result> result, int limit, boolean hasNext) voidAccessController.preScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Scan scan) voidAccessController.preSetNamespaceQuota(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace, GlobalQuotaSettings quotas) voidAccessController.preSetRegionServerQuota(ObserverContext<MasterCoprocessorEnvironment> ctx, String regionServer, GlobalQuotaSettings quotas) voidAccessController.preSetSplitOrMergeEnabled(ObserverContext<MasterCoprocessorEnvironment> ctx, boolean newValue, MasterSwitchType switchType) voidAccessController.preSetTableQuota(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, GlobalQuotaSettings quotas) voidAccessController.preSetUserQuota(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, String namespace, GlobalQuotaSettings quotas) voidAccessController.preSetUserQuota(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, GlobalQuotaSettings quotas) voidAccessController.preSetUserQuota(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, TableName tableName, GlobalQuotaSettings quotas) voidAccessController.preShutdown(ObserverContext<MasterCoprocessorEnvironment> c) voidAccessController.preSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot, TableDescriptor hTableDescriptor) voidAccessController.preSplitRegion(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, byte[] splitRow) voidAccessController.preStopMaster(ObserverContext<MasterCoprocessorEnvironment> c) voidSnapshotScannerHDFSAclController.preStopMaster(ObserverContext<MasterCoprocessorEnvironment> c) voidAccessController.preStopRegionServer(ObserverContext<RegionServerCoprocessorEnvironment> ctx) voidAccessController.preSwitchExceedThrottleQuota(ObserverContext<MasterCoprocessorEnvironment> ctx, boolean enable) voidAccessController.preSwitchRpcThrottle(ObserverContext<MasterCoprocessorEnvironment> ctx, boolean enable) voidAccessController.preTableFlush(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) voidAccessController.preTruncateTable(ObserverContext<MasterCoprocessorEnvironment> c, TableName tableName) voidAccessController.preUnassign(ObserverContext<MasterCoprocessorEnvironment> c, RegionInfo regionInfo) voidAccessController.preUpdateMasterConfiguration(ObserverContext<MasterCoprocessorEnvironment> ctx, org.apache.hadoop.conf.Configuration preReloadConf) voidAccessController.preUpdateRegionServerConfiguration(ObserverContext<RegionServerCoprocessorEnvironment> ctx, org.apache.hadoop.conf.Configuration preReloadConf) voidAccessController.preUpdateReplicationPeerConfig(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId, ReplicationPeerConfig peerConfig) voidAccessController.requireAccess(ObserverContext<?> ctx, String request, TableName tableName, Permission.Action... permissions) voidAccessController.requireGlobalPermission(ObserverContext<?> ctx, String request, Permission.Action perm, String namespace) voidAccessController.requireGlobalPermission(ObserverContext<?> ctx, String request, Permission.Action perm, TableName tableName, Map<byte[], ? extends Collection<byte[]>> familyMap) voidAccessController.requireNamespacePermission(ObserverContext<?> ctx, String request, String namespace, Permission.Action... permissions) voidAccessController.requireNamespacePermission(ObserverContext<?> ctx, String request, String namespace, TableName tableName, Map<byte[], ? extends Collection<byte[]>> familyMap, Permission.Action... permissions) voidAccessController.requirePermission(ObserverContext<?> ctx, String request, Permission.Action perm) voidAccessController.requirePermission(ObserverContext<?> ctx, String request, TableName tableName, byte[] family, byte[] qualifier, Permission.Action... permissions) voidAccessController.requireTablePermission(ObserverContext<?> ctx, String request, TableName tableName, byte[] family, byte[] qualifier, Permission.Action... permissions) private static voidCoprocessorWhitelistMasterObserver.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
Methods in org.apache.hadoop.hbase.security.visibility with parameters of type ObserverContextModifier and TypeMethodDescriptionVisibilityController.postAppendBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) VisibilityReplication.postCreateReplicationEndPoint(ObserverContext<RegionServerCoprocessorEnvironment> ctx, ReplicationEndpoint endpoint) VisibilityController.postIncrementBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation mutation, List<Pair<Cell, Cell>> cellPairs) VisibilityController.postInstantiateDeleteTracker(ObserverContext<RegionCoprocessorEnvironment> ctx, DeleteTracker delTracker) voidVisibilityController.postOpen(ObserverContext<RegionCoprocessorEnvironment> e) Region related hooksvoidVisibilityController.postScannerClose(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s) VisibilityController.postScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Scan scan, RegionScanner s) voidVisibilityController.postSetSplitOrMergeEnabled(ObserverContext<MasterCoprocessorEnvironment> ctx, boolean newValue, MasterSwitchType switchType) voidVisibilityController.postStartMaster(ObserverContext<MasterCoprocessorEnvironment> ctx) Master related hooksvoidVisibilityController.preBatchMutate(ObserverContext<RegionCoprocessorEnvironment> c, MiniBatchOperationInProgress<Mutation> miniBatchOp) voidVisibilityController.preDisableTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) voidVisibilityController.preGetOp(ObserverContext<RegionCoprocessorEnvironment> e, Get get, List<Cell> results) VisibilityController.preModifyTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, TableDescriptor currentDescriptor, TableDescriptor newDescriptor) voidVisibilityController.prePrepareTimeStampForDeleteVersion(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation delete, Cell cell, byte[] byteNow, Get get) voidVisibilityController.preScannerClose(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s) booleanVisibilityController.preScannerNext(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s, List<Result> result, int limit, boolean hasNext) voidVisibilityController.preScannerOpen(ObserverContext<RegionCoprocessorEnvironment> e, Scan scan) -
Uses of ObserverContext in org.apache.hadoop.hbase.tool
Methods in org.apache.hadoop.hbase.tool with parameters of type ObserverContextModifier and TypeMethodDescriptionvoidWriteSinkCoprocessor.preBatchMutate(ObserverContext<RegionCoprocessorEnvironment> c, MiniBatchOperationInProgress<Mutation> miniBatchOp) voidWriteSinkCoprocessor.preOpen(ObserverContext<RegionCoprocessorEnvironment> e)