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

Packages that use ObserverContext

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

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

Methods in org.apache.hadoop.hbase.constraint with parameters of type ObserverContext

Modifier and Type	Method and Description
boolean	ConstraintProcessor.postScannerFilterRow(ObserverContext<RegionCoprocessorEnvironment> e, InternalScanner s, Cell curRowCell, boolean hasMore)
void	ConstraintProcessor.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 ObserverContext

Modifier and Type	Class and Description
private class	CoprocessorHost.ObserverOperation<O>
class	CoprocessorHost.ObserverOperationWithoutResult<O>
class	CoprocessorHost.ObserverOperationWithResult<O,R>
class	ObserverContextImpl<E extends CoprocessorEnvironment> This is the only implementation of ObserverContext, which serves as the interface for third-party Coprocessor developers.

Methods in org.apache.hadoop.hbase.coprocessor that return ObserverContext

Modifier and Type	Method and Description
static <E extends CoprocessorEnvironment> ObserverContext<E>	ObserverContextImpl.createAndPrepare(E env) Deprecated.

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

Modifier and Type	Method and Description
private void	MetaTableMetrics.ExampleRegionObserverMeta.clientMetricRegisterAndMark(ObserverContext<RegionCoprocessorEnvironment> e)
private boolean	MetaTableMetrics.ExampleRegionObserverMeta.isMetaTableOp(ObserverContext<RegionCoprocessorEnvironment> e)
private void	MetaTableMetrics.ExampleRegionObserverMeta.opMetricRegisterAndMark(ObserverContext<RegionCoprocessorEnvironment> e, Row op)
private void	MetaTableMetrics.ExampleRegionObserverMeta.opWithClientMetricRegisterAndMark(ObserverContext<RegionCoprocessorEnvironment> e, Object op)
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 peer
default void	MasterObserver.postAddRSGroup(ObserverContext<MasterCoprocessorEnvironment> ctx, String name) Called after a new region server group is added
default Result	RegionObserver.postAppend(ObserverContext<RegionCoprocessorEnvironment> c, Append append, Result result) Called after Append
default void	MasterObserver.postAssign(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo regionInfo) Called after the region assignment has been requested.
default void	MasterObserver.postBalance(ObserverContext<MasterCoprocessorEnvironment> ctx, List<RegionPlan> plans) Called after the balancing plan has been submitted.
default void	MasterObserver.postBalanceRSGroup(ObserverContext<MasterCoprocessorEnvironment> ctx, String groupName, boolean balancerRan) Called after a region server group is removed
default 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<RegionCoprocessorEnvironment> c, MiniBatchOperationInProgress<Mutation> miniBatchOp) This will be called after applying a batch of Mutations on a region.
default void	RegionObserver.postBatchMutateIndispensably(ObserverContext<RegionCoprocessorEnvironment> ctx, MiniBatchOperationInProgress<Mutation> miniBatchOp, boolean success) Called after the completion of batch put/delete and will be called even if the batch operation fails.
default void	RegionObserver.postBulkLoadHFile(ObserverContext<RegionCoprocessorEnvironment> ctx, List<Pair<byte[],String>> stagingFamilyPaths, Map<byte[],List<org.apache.hadoop.fs.Path>> finalPaths) Called after bulkLoadHFile.
default boolean	RegionObserver.postCheckAndDelete(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Delete delete, boolean result) Called after checkAndDelete
default boolean	RegionObserver.postCheckAndPut(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Put put, boolean result) Called after checkAndPut
default void	RegionServerObserver.postClearCompactionQueues(ObserverContext<RegionServerCoprocessorEnvironment> ctx) This will be called after clearing compaction queues
default void	MasterObserver.postClearDeadServers(ObserverContext<MasterCoprocessorEnvironment> ctx, List<ServerName> servers, List<ServerName> notClearedServers) Called after clear dead region servers.
default void	MasterObserver.postCloneSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot, TableDescriptor tableDescriptor) Called after a snapshot clone operation has been requested.
default void	RegionObserver.postClose(ObserverContext<RegionCoprocessorEnvironment> c, boolean abortRequested) Called after the region is reported as closed to the master.
default void	RegionObserver.postCloseRegionOperation(ObserverContext<RegionCoprocessorEnvironment> ctx, Region.Operation operation) Called after releasing read lock in Region.closeRegionOperation().
default void	RegionObserver.postCommitStoreFile(ObserverContext<RegionCoprocessorEnvironment> ctx, byte[] family, org.apache.hadoop.fs.Path srcPath, org.apache.hadoop.fs.Path dstPath) Called after moving bulk loaded hfile to region directory.
default void	RegionObserver.postCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store, StoreFile resultFile, CompactionLifeCycleTracker tracker, CompactionRequest request) Called after compaction has completed and the new store file has been moved in to place.
default void	RegionObserver.postCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c, Store store, List<? extends StoreFile> selected, CompactionLifeCycleTracker tracker, CompactionRequest request) Called after the StoreFiles 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 after HMaster 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 currentDescriptor) Deprecated. Since 2.1. Will be removed in 3.0.
default void	MasterObserver.postCompletedModifyTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, TableDescriptor oldDescriptor, TableDescriptor currentDescriptor) Called after to modifying a table's properties.
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 after HMaster 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<RegionCoprocessorEnvironment> c, Delete delete, WALEdit edit, Durability durability) Called after the client deletes a value.
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 peer
default 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 peer
default void	MasterObserver.postEnableTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called after the enableTable operation has been requested.
default void	EndpointObserver.postEndpointInvocation(ObserverContext<RegionCoprocessorEnvironment> ctx, com.google.protobuf.Service service, String methodName, com.google.protobuf.Message request, com.google.protobuf.Message.Builder responseBuilder) Called after an Endpoint service method is invoked.
default boolean	RegionObserver.postExists(ObserverContext<RegionCoprocessorEnvironment> c, Get get, boolean exists) Called after the client tests for existence using a Get.
default void	RegionObserver.postFlush(ObserverContext<RegionCoprocessorEnvironment> c, FlushLifeCycleTracker tracker) Called after the memstore is flushed to disk.
default void	RegionObserver.postFlush(ObserverContext<RegionCoprocessorEnvironment> c, Store store, StoreFile resultFile, FlushLifeCycleTracker tracker) Called after a Store's memstore is flushed to disk.
default void	MasterObserver.postGetClusterMetrics(ObserverContext<MasterCoprocessorEnvironment> ctx, ClusterMetrics status) Called after get cluster status.
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<RegionCoprocessorEnvironment> c, Get get, List<Cell> result) Called after the client performs a Get
default 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 peer
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 Result	RegionObserver.postIncrement(ObserverContext<RegionCoprocessorEnvironment> c, Increment increment, Result result) Called after increment
default DeleteTracker	RegionObserver.postInstantiateDeleteTracker(ObserverContext<RegionCoprocessorEnvironment> ctx, DeleteTracker delTracker) Deprecated. Since 2.0 with out any replacement and will be removed in 3.0
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.postListReplicationPeers(ObserverContext<MasterCoprocessorEnvironment> ctx, String regex) Called after list replication peers.
default void	MasterObserver.postListSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot) Called after listSnapshots request has been processed.
default void	MasterObserver.postLockHeartbeat(ObserverContext<MasterCoprocessorEnvironment> ctx) Called after heartbeat to a lock.
default void	RegionObserver.postMemStoreCompaction(ObserverContext<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.postModifyNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor currentNsDescriptor) Deprecated. Since 2.1. Will be removed in 3.0.
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 currentDescriptor) Deprecated. Since 2.1. Will be removed in 3.0.
default void	MasterObserver.postModifyTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, TableDescriptor oldDescriptor, TableDescriptor currentDescriptor) Called after the modifyTable operation has been requested.
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 group
default void	MasterObserver.postMoveServersAndTables(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<Address> servers, Set<TableName> tables, String targetGroup) Called after servers are moved to target region server group
default void	MasterObserver.postMoveTables(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<TableName> tables, String targetGroup) Called after servers are moved to target region server group
default Cell	RegionObserver.postMutationBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, RegionObserver.MutationType opType, Mutation mutation, Cell oldCell, Cell newCell) Called after a new cell has been created during an increment operation, but before it is committed to the WAL or memstore.
default void	RegionObserver.postOpen(ObserverContext<RegionCoprocessorEnvironment> c) Called after the region is reported as open to the master.
default void	RegionObserver.postPut(ObserverContext<RegionCoprocessorEnvironment> c, Put put, WALEdit edit, Durability durability) Called after the client stores a value.
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 peer
default void	MasterObserver.postRemoveRSGroup(ObserverContext<MasterCoprocessorEnvironment> ctx, String name) Called after a region server group is removed
default void	MasterObserver.postRemoveServers(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<Address> servers) Called after servers are removed from 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. This is maintained for internal usage by AccessController. Do not use these hooks in custom co-processors.
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.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 completed
default 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<RegionCoprocessorEnvironment> ctx, InternalScanner s) Called after the client closes a scanner.
default boolean	RegionObserver.postScannerFilterRow(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s, Cell curRowCell, boolean hasMore) This will be called by the scan flow when the current scanned row is being filtered out by the filter.
default boolean	RegionObserver.postScannerNext(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s, List<Result> result, int limit, boolean hasNext) Called after the client asks for the next row on a scanner.
default RegionScanner	RegionObserver.postScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Scan scan, RegionScanner s) Called after the client opens a new scanner.
default void	MasterObserver.postSetNamespaceQuota(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace, GlobalQuotaSettings quotas) Called after the quota for the namespace is stored.
default void	MasterObserver.postSetSplitOrMergeEnabled(ObserverContext<MasterCoprocessorEnvironment> ctx, boolean newValue, MasterSwitchType switchType) Called after setting split / merge switch
default 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, GlobalQuotaSettings quotas) Called after the quota for the user 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, 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<RegionCoprocessorEnvironment> ctx, Region.Operation operation) This will be called for region operations where read lock is acquired in Region.startRegionOperation().
default StoreFileReader	RegionObserver.postStoreFileReaderOpen(ObserverContext<RegionCoprocessorEnvironment> ctx, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path p, FSDataInputStreamWrapper in, long size, CacheConfig cacheConf, Reference r, StoreFileReader reader) Deprecated. For Phoenix only, StoreFileReader is not a stable interface.
default void	MasterObserver.postTableFlush(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called after the table memstore is flushed to disk.
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, boolean force) Called after the region unassignment has been requested.
default void	MasterObserver.postUpdateReplicationPeerConfig(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId, ReplicationPeerConfig peerConfig) Called after update peerConfig for the specified peer
default void	RegionObserver.postWALRestore(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, RegionInfo info, WALKey logKey, WALEdit logEdit) Called after a WALEdit replayed for this region.
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 WAL
default void	WALObserver.postWALWrite(ObserverContext<? extends WALCoprocessorEnvironment> ctx, RegionInfo info, WALKey logKey, WALEdit logEdit) Deprecated. Since hbase-2.0.0. To be replaced with an alternative that does not expose InterfaceAudience classes such as WALKey and WALEdit. Will be removed in hbase-3.0.0.
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 peer
default void	MasterObserver.preAddRSGroup(ObserverContext<MasterCoprocessorEnvironment> ctx, String name) Called before a new region server group is added
default Result	RegionObserver.preAppend(ObserverContext<RegionCoprocessorEnvironment> c, Append append) Called before Append.
default Result	RegionObserver.preAppendAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c, Append append) Called before Append but after acquiring rowlock.
default void	MasterObserver.preAssign(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo regionInfo) Called prior to assigning a specific region.
default void	MasterObserver.preBalance(ObserverContext<MasterCoprocessorEnvironment> ctx) 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) Called before a region server group is removed
default 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<RegionCoprocessorEnvironment> c, MiniBatchOperationInProgress<Mutation> miniBatchOp) This will be called for every batch mutation operation happening at the server.
default void	RegionObserver.preBulkLoadHFile(ObserverContext<RegionCoprocessorEnvironment> ctx, List<Pair<byte[],String>> familyPaths) Called before bulkLoadHFile.
default boolean	RegionObserver.preCheckAndDelete(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Delete delete, boolean result) Called before checkAndDelete.
default boolean	RegionObserver.preCheckAndDeleteAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Delete delete, boolean result) Called before checkAndDelete but after acquiring rowock.
default boolean	RegionObserver.preCheckAndPut(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Put put, boolean result) Called before checkAndPut.
default boolean	RegionObserver.preCheckAndPutAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Put put, boolean result) Called before checkAndPut but after acquiring rowlock.
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 queues
default void	MasterObserver.preClearDeadServers(ObserverContext<MasterCoprocessorEnvironment> ctx) Called before clear dead region servers.
default void	MasterObserver.preCloneSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot, TableDescriptor tableDescriptor) Called before a snapshot is cloned.
default void	RegionObserver.preClose(ObserverContext<RegionCoprocessorEnvironment> c, boolean abortRequested) Called before the region is reported as closed to the master.
default void	RegionObserver.preCommitStoreFile(ObserverContext<RegionCoprocessorEnvironment> ctx, byte[] family, List<Pair<org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path>> pairs) Called before moving bulk loaded hfile to region directory.
default InternalScanner	RegionObserver.preCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request) Called prior to writing the StoreFiles selected for compaction into a new StoreFile.
default void	RegionObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store, ScanType scanType, ScanOptions options, CompactionLifeCycleTracker tracker, CompactionRequest request) Called before we open store scanner for compaction.
default void	RegionObserver.preCompactSelection(ObserverContext<RegionCoprocessorEnvironment> c, Store store, List<? extends StoreFile> candidates, CompactionLifeCycleTracker tracker) Called prior to selecting the StoreFiles to compact from the list of available candidates.
default void	MasterObserver.preCreateNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor ns) Called before a new namespace is created by HMaster.
default void	MasterObserver.preCreateTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableDescriptor desc, RegionInfo[] regions) Called before a new table is created by HMaster.
default void	MasterObserver.preCreateTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx, TableDescriptor desc, RegionInfo[] regions) Called before a new table is created by HMaster.
default void	MasterObserver.preDecommissionRegionServers(ObserverContext<MasterCoprocessorEnvironment> ctx, List<ServerName> servers, boolean offload) Called before decommission region servers.
default void	RegionObserver.preDelete(ObserverContext<RegionCoprocessorEnvironment> c, Delete delete, WALEdit edit, Durability durability) Called before the client deletes a value.
void	MetaTableMetrics.ExampleRegionObserverMeta.preDelete(ObserverContext<RegionCoprocessorEnvironment> e, Delete delete, WALEdit edit, Durability durability)
default void	MasterObserver.preDeleteNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace) Called before HMaster deletes a namespace
default void	MasterObserver.preDeleteSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot) Called before a snapshot is deleted.
default void	MasterObserver.preDeleteTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called before HMaster deletes a table.
default void	MasterObserver.preDeleteTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called before HMaster deletes a table.
default void	MasterObserver.preDisableReplicationPeer(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId) Called before disable a replication peer
default 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 peer
default 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 com.google.protobuf.Message	EndpointObserver.preEndpointInvocation(ObserverContext<RegionCoprocessorEnvironment> ctx, com.google.protobuf.Service service, String methodName, com.google.protobuf.Message request) Called before an Endpoint service method is invoked.
default boolean	RegionObserver.preExists(ObserverContext<RegionCoprocessorEnvironment> c, Get get, boolean exists) Called before the client tests for existence using a Get.
default void	RegionObserver.preFlush(ObserverContext<RegionCoprocessorEnvironment> c, FlushLifeCycleTracker tracker) Called before the memstore is flushed to disk.
default InternalScanner	RegionObserver.preFlush(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, FlushLifeCycleTracker tracker) Called before a Store's memstore is flushed to disk.
default void	RegionObserver.preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store, ScanOptions options, FlushLifeCycleTracker tracker) Called before we open store scanner for flush.
default void	MasterObserver.preGetClusterMetrics(ObserverContext<MasterCoprocessorEnvironment> ctx) Called before get cluster status.
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.
default void	RegionObserver.preGetOp(ObserverContext<RegionCoprocessorEnvironment> c, Get get, List<Cell> result) Called before the client performs a Get
void	MetaTableMetrics.ExampleRegionObserverMeta.preGetOp(ObserverContext<RegionCoprocessorEnvironment> e, Get get, List<Cell> results)
default 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 peer
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 Result	RegionObserver.preIncrement(ObserverContext<RegionCoprocessorEnvironment> c, Increment increment) Called before Increment.
default Result	RegionObserver.preIncrementAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c, Increment increment) Called before Increment but after acquiring rowlock.
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.preListReplicationPeers(ObserverContext<MasterCoprocessorEnvironment> ctx, String regex) Called before list replication peers.
default void	MasterObserver.preListSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot) Called before listSnapshots request has been processed.
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	RegionObserver.preMemStoreCompaction(ObserverContext<RegionCoprocessorEnvironment> c, Store store) Called before in memory compaction started.
default InternalScanner	RegionObserver.preMemStoreCompactionCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner) Called before we do in memory compaction.
default void	RegionObserver.preMemStoreCompactionCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store, ScanOptions options) Called before we open store scanner for in memory compaction.
default void	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 void	MasterObserver.preModifyNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor newNsDescriptor) Deprecated. Since 2.1. Will be removed in 3.0.
default void	MasterObserver.preModifyNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor currentNsDescriptor, NamespaceDescriptor newNsDescriptor) Called prior to modifying a namespace's properties.
default void	MasterObserver.preModifyTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, TableDescriptor newDescriptor) Deprecated. Since 2.1. Will be removed in 3.0.
default void	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 newDescriptor) Deprecated. Since 2.1. Will be removed in 3.0.
default void	MasterObserver.preModifyTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, TableDescriptor currentDescriptor, TableDescriptor newDescriptor) Called prior to modifying a table's properties.
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 group
default void	MasterObserver.preMoveServersAndTables(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<Address> servers, Set<TableName> tables, String targetGroup) Called before servers are moved to target region server group
default void	MasterObserver.preMoveTables(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<TableName> tables, String targetGroup) Called before tables are moved to target region server group
default void	RegionObserver.preOpen(ObserverContext<RegionCoprocessorEnvironment> c) Called before the region is reported as open to the master.
default void	BulkLoadObserver.prePrepareBulkLoad(ObserverContext<RegionCoprocessorEnvironment> ctx) Called as part of SecureBulkLoadEndpoint.prepareBulkLoad() RPC call.
default void	RegionObserver.prePrepareTimeStampForDeleteVersion(ObserverContext<RegionCoprocessorEnvironment> c, Mutation mutation, Cell cell, byte[] byteNow, Get get) Deprecated. Since hbase-2.0.0. No replacement. To be removed in hbase-3.0.0 and replaced with something that doesn't expose IntefaceAudience.Private classes.
default void	RegionObserver.prePut(ObserverContext<RegionCoprocessorEnvironment> c, Put put, WALEdit edit, Durability durability) Called before the client stores a value.
void	MetaTableMetrics.ExampleRegionObserverMeta.prePut(ObserverContext<RegionCoprocessorEnvironment> e, Put put, WALEdit edit, Durability durability)
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 peer
default void	MasterObserver.preRemoveRSGroup(ObserverContext<MasterCoprocessorEnvironment> ctx, String name) Called before a region server group is removed
default void	MasterObserver.preRemoveServers(ObserverContext<MasterCoprocessorEnvironment> ctx, Set<Address> servers) Called before servers are removed from 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. This is maintained for internal usage by AccessController. Do not use these hooks in custom co-processors.
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	RegionServerObserver.preRollWALWriterRequest(ObserverContext<RegionServerCoprocessorEnvironment> ctx) This will be called before executing user request to roll a region server WAL.
default void	RegionObserver.preScannerClose(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s) Called before the client closes a scanner.
default boolean	RegionObserver.preScannerNext(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s, List<Result> result, int limit, boolean hasNext) Called before the client asks for the next row on a scanner.
default void	RegionObserver.preScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Scan scan) Called before the client opens a new scanner.
default void	MasterObserver.preSetNamespaceQuota(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace, GlobalQuotaSettings quotas) Called before the quota for the namespace 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, GlobalQuotaSettings quotas) Called before the quota for the user 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, 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 this HMaster 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 transaction
default 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 this HMaster process.
default void	RegionServerObserver.preStopRegionServer(ObserverContext<RegionServerCoprocessorEnvironment> ctx) Called before stopping region server.
default StoreFileReader	RegionObserver.preStoreFileReaderOpen(ObserverContext<RegionCoprocessorEnvironment> ctx, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path p, FSDataInputStreamWrapper in, long size, CacheConfig cacheConf, Reference r, StoreFileReader reader) Deprecated. For Phoenix only, StoreFileReader is not a stable interface.
default void	RegionObserver.preStoreScannerOpen(ObserverContext<RegionCoprocessorEnvironment> ctx, Store store, ScanOptions options) Called before a store opens a new scanner.
default void	MasterObserver.preTableFlush(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called before the table memstore is flushed to disk.
default void	MasterObserver.preTruncateTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called before HMaster truncates a table.
default void	MasterObserver.preTruncateTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName) Called before HMaster truncates a table.
default void	MasterObserver.preUnassign(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo regionInfo, boolean force) Called prior to unassigning a given region.
default void	MasterObserver.preUpdateReplicationPeerConfig(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId, ReplicationPeerConfig peerConfig) Called before update peerConfig for the specified peer
default void	RegionObserver.preWALRestore(ObserverContext<? extends RegionCoprocessorEnvironment> ctx, RegionInfo info, WALKey logKey, WALEdit logEdit) Called before a WALEdit replayed for this region.
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 WAL
default void	WALObserver.preWALWrite(ObserverContext<? extends WALCoprocessorEnvironment> ctx, RegionInfo info, WALKey logKey, WALEdit logEdit) Deprecated. Since hbase-2.0.0. To be replaced with an alternative that does not expose InterfaceAudience classes such as WALKey and WALEdit. Will be removed in hbase-3.0.0.
private void	MetaTableMetrics.ExampleRegionObserverMeta.regionMetricRegisterAndMark(ObserverContext<RegionCoprocessorEnvironment> e, Row op)
private void	MetaTableMetrics.ExampleRegionObserverMeta.registerLossyCountingMeterIfNotPresent(ObserverContext<RegionCoprocessorEnvironment> e, String requestMeter, LossyCounting lossyCounting) Registers and counts lossyCount for Meters that kept by lossy counting.
private void	MetaTableMetrics.ExampleRegionObserverMeta.registerMeterIfNotPresent(ObserverContext<RegionCoprocessorEnvironment> e, String requestMeter)
private void	MetaTableMetrics.ExampleRegionObserverMeta.tableMetricRegisterAndMark(ObserverContext<RegionCoprocessorEnvironment> e, Row op)

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

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

Modifier and Type	Method and Description
void	ExampleRegionObserverWithMetrics.ExampleRegionObserver.postCompactSelection(ObserverContext<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<RegionCoprocessorEnvironment> c, FlushLifeCycleTracker tracker)
void	ExampleRegionObserverWithMetrics.ExampleRegionObserver.postFlush(ObserverContext<RegionCoprocessorEnvironment> c, Store store, StoreFile resultFile, FlushLifeCycleTracker tracker)
void	ExampleRegionObserverWithMetrics.ExampleRegionObserver.postGetOp(ObserverContext<RegionCoprocessorEnvironment> e, Get get, List<Cell> results)
InternalScanner	WriteHeavyIncrementObserver.preCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request)
InternalScanner	ValueRewritingObserver.preCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request)
void	WriteHeavyIncrementObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store, ScanType scanType, ScanOptions options, CompactionLifeCycleTracker tracker, CompactionRequest request)
void	ZooKeeperScanPolicyObserver.preCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store, ScanType scanType, ScanOptions options, CompactionLifeCycleTracker tracker, CompactionRequest request)
void	ExampleMasterObserverWithMetrics.preCreateTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableDescriptor desc, RegionInfo[] regions)
void	ExampleMasterObserverWithMetrics.preDisableTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName)
InternalScanner	WriteHeavyIncrementObserver.preFlush(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, FlushLifeCycleTracker tracker)
void	WriteHeavyIncrementObserver.preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store, ScanOptions options, FlushLifeCycleTracker tracker)
void	ZooKeeperScanPolicyObserver.preFlushScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store, ScanOptions options, FlushLifeCycleTracker tracker)
void	WriteHeavyIncrementObserver.preGetOp(ObserverContext<RegionCoprocessorEnvironment> c, Get get, List<Cell> result)
void	ExampleRegionObserverWithMetrics.ExampleRegionObserver.preGetOp(ObserverContext<RegionCoprocessorEnvironment> e, Get get, List<Cell> results)
Result	WriteHeavyIncrementObserver.preIncrement(ObserverContext<RegionCoprocessorEnvironment> c, Increment increment)
InternalScanner	WriteHeavyIncrementObserver.preMemStoreCompactionCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner)
void	WriteHeavyIncrementObserver.preMemStoreCompactionCompactScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Store store, ScanOptions options)
void	ScanModifyingObserver.preScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Scan scan)
void	WriteHeavyIncrementObserver.preStoreScannerOpen(ObserverContext<RegionCoprocessorEnvironment> ctx, Store store, ScanOptions options)

Uses of ObserverContext in org.apache.hadoop.hbase.master

Classes in org.apache.hadoop.hbase.master that implement ObserverContext

Modifier and Type	Class and Description
(package private) class	MasterCoprocessorHost.MasterObserverOperation

Uses of ObserverContext in org.apache.hadoop.hbase.quotas

Methods in org.apache.hadoop.hbase.quotas with parameters of type ObserverContext

Modifier and Type	Method and Description
void	MasterQuotasObserver.postDeleteNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace)
void	MasterQuotasObserver.postDeleteTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName)

Uses of ObserverContext in org.apache.hadoop.hbase.regionserver

Classes in org.apache.hadoop.hbase.regionserver that implement ObserverContext

Modifier and Type	Class and Description
(package private) class	RegionCoprocessorHost.BulkLoadObserverOperation
(package private) class	RegionCoprocessorHost.RegionObserverOperationWithoutResult
(package private) class	RegionServerCoprocessorHost.RegionServerObserverOperation

Uses of ObserverContext in org.apache.hadoop.hbase.regionserver.wal

Classes in org.apache.hadoop.hbase.regionserver.wal that implement ObserverContext

Modifier and Type	Class and Description
(package private) class	WALCoprocessorHost.WALObserverOperation

Uses of ObserverContext in org.apache.hadoop.hbase.replication.regionserver

Methods in org.apache.hadoop.hbase.replication.regionserver with parameters of type ObserverContext

Modifier and Type	Method and Description
void	ReplicationObserver.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 ObserverContext

Modifier and Type	Method and Description
void	RSGroupAdminEndpoint.postClearDeadServers(ObserverContext<MasterCoprocessorEnvironment> ctx, List<ServerName> servers, List<ServerName> notClearedServers)
void	RSGroupAdminEndpoint.postCreateTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableDescriptor desc, RegionInfo[] regions)
void	RSGroupAdminEndpoint.postDeleteTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName)
void	RSGroupAdminEndpoint.preCloneSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot, TableDescriptor desc)
void	RSGroupAdminEndpoint.preCreateNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor ns)
void	RSGroupAdminEndpoint.preCreateTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx, TableDescriptor desc, RegionInfo[] regions)
void	RSGroupAdminEndpoint.preModifyNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor ns)

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

Methods in org.apache.hadoop.hbase.security.access with parameters of type ObserverContext

Modifier and Type	Method and Description
void	AccessController.checkLockPermissions(ObserverContext<?> ctx, String namespace, TableName tableName, RegionInfo[] regionInfos, String reason)
User	AccessController.getActiveUser(ObserverContext<?> ctx) Returns the active user to which authorization checks should be applied.
private void	AccessController.internalPreRead(ObserverContext<RegionCoprocessorEnvironment> c, Query query, AccessController.OpType opType)
void	AccessController.postAbortProcedure(ObserverContext<MasterCoprocessorEnvironment> ctx)
void	AccessController.postCompletedCreateTableAction(ObserverContext<MasterCoprocessorEnvironment> c, TableDescriptor desc, RegionInfo[] regions)
ReplicationEndpoint	AccessController.postCreateReplicationEndPoint(ObserverContext<RegionServerCoprocessorEnvironment> ctx, ReplicationEndpoint endpoint)
void	AccessController.postDelete(ObserverContext<RegionCoprocessorEnvironment> c, Delete delete, WALEdit edit, Durability durability)
void	AccessController.postDeleteNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace)
void	AccessController.postDeleteTable(ObserverContext<MasterCoprocessorEnvironment> c, TableName tableName)
void	AccessController.postEndpointInvocation(ObserverContext<RegionCoprocessorEnvironment> ctx, com.google.protobuf.Service service, String methodName, com.google.protobuf.Message request, com.google.protobuf.Message.Builder responseBuilder)
void	AccessController.postGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx, List<TableName> tableNamesList, List<TableDescriptor> descriptors, String regex)
void	AccessController.postGetTableNames(ObserverContext<MasterCoprocessorEnvironment> ctx, List<TableDescriptor> descriptors, String regex)
void	AccessController.postListNamespaceDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx, List<NamespaceDescriptor> descriptors)
void	AccessController.postModifyTable(ObserverContext<MasterCoprocessorEnvironment> c, TableName tableName, TableDescriptor htd)
Cell	AccessController.postMutationBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, RegionObserver.MutationType opType, Mutation mutation, Cell oldCell, Cell newCell)
void	AccessController.postOpen(ObserverContext<RegionCoprocessorEnvironment> c)
void	AccessController.postPut(ObserverContext<RegionCoprocessorEnvironment> c, Put put, WALEdit edit, Durability durability)
void	AccessController.postRollWALWriterRequest(ObserverContext<RegionServerCoprocessorEnvironment> ctx)
void	AccessController.postScannerClose(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s)
boolean	AccessController.postScannerFilterRow(ObserverContext<RegionCoprocessorEnvironment> e, InternalScanner s, Cell curRowCell, boolean hasMore)
RegionScanner	AccessController.postScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Scan scan, RegionScanner s)
void	AccessController.postStartMaster(ObserverContext<MasterCoprocessorEnvironment> ctx)
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)
Result	AccessController.preAppend(ObserverContext<RegionCoprocessorEnvironment> c, Append append)
Result	AccessController.preAppendAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c, Append append)
void	AccessController.preAssign(ObserverContext<MasterCoprocessorEnvironment> c, RegionInfo regionInfo)
void	AccessController.preBalance(ObserverContext<MasterCoprocessorEnvironment> c)
void	AccessController.preBalanceSwitch(ObserverContext<MasterCoprocessorEnvironment> c, boolean newValue)
void	AccessController.preBatchMutate(ObserverContext<RegionCoprocessorEnvironment> c, MiniBatchOperationInProgress<Mutation> miniBatchOp)
void	AccessController.preBulkLoadHFile(ObserverContext<RegionCoprocessorEnvironment> ctx, List<Pair<byte[],String>> familyPaths) Verifies user has CREATE privileges on the Column Families involved in the bulkLoadHFile request.
boolean	AccessController.preCheckAndDelete(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Delete delete, boolean result)
boolean	AccessController.preCheckAndDeleteAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Delete delete, boolean result)
boolean	AccessController.preCheckAndPut(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator op, ByteArrayComparable comparator, Put put, boolean result)
boolean	AccessController.preCheckAndPutAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c, byte[] row, byte[] family, byte[] qualifier, CompareOperator opp, ByteArrayComparable comparator, Put put, boolean result)
void	AccessController.preCleanupBulkLoad(ObserverContext<RegionCoprocessorEnvironment> ctx) Authorization security check for SecureBulkLoadProtocol.cleanupBulkLoad()
void	AccessController.preClearCompactionQueues(ObserverContext<RegionServerCoprocessorEnvironment> ctx)
void	AccessController.preClearDeadServers(ObserverContext<MasterCoprocessorEnvironment> ctx)
void	AccessController.preCloneSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot, TableDescriptor hTableDescriptor)
void	AccessController.preClose(ObserverContext<RegionCoprocessorEnvironment> c, boolean abortRequested)
InternalScanner	AccessController.preCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request)
void	AccessController.preCreateNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor ns)
void	CoprocessorWhitelistMasterObserver.preCreateTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableDescriptor htd, RegionInfo[] regions)
void	AccessController.preCreateTable(ObserverContext<MasterCoprocessorEnvironment> c, TableDescriptor desc, RegionInfo[] regions) Observer implementations
void	AccessController.preDecommissionRegionServers(ObserverContext<MasterCoprocessorEnvironment> ctx, List<ServerName> servers, boolean offload)
void	AccessController.preDelete(ObserverContext<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)
com.google.protobuf.Message	AccessController.preEndpointInvocation(ObserverContext<RegionCoprocessorEnvironment> ctx, com.google.protobuf.Service service, String methodName, com.google.protobuf.Message request)
boolean	AccessController.preExists(ObserverContext<RegionCoprocessorEnvironment> c, Get get, boolean exists)
void	AccessController.preFlush(ObserverContext<RegionCoprocessorEnvironment> c, FlushLifeCycleTracker tracker)
void	AccessController.preGetLocks(ObserverContext<MasterCoprocessorEnvironment> ctx)
void	AccessController.preGetNamespaceDescriptor(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace)
void	AccessController.preGetOp(ObserverContext<RegionCoprocessorEnvironment> c, Get get, List<Cell> result)
void	AccessController.preGetProcedures(ObserverContext<MasterCoprocessorEnvironment> ctx)
void	AccessController.preGetReplicationPeerConfig(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId)
void	AccessController.preGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx, List<TableName> tableNamesList, List<TableDescriptor> descriptors, String regex)
Result	AccessController.preIncrement(ObserverContext<RegionCoprocessorEnvironment> c, Increment increment)
Result	AccessController.preIncrementAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c, Increment increment)
void	AccessController.preListDecommissionedRegionServers(ObserverContext<MasterCoprocessorEnvironment> ctx)
void	AccessController.preListReplicationPeers(ObserverContext<MasterCoprocessorEnvironment> ctx, String regex)
void	AccessController.preListSnapshot(ObserverContext<MasterCoprocessorEnvironment> ctx, SnapshotDescription snapshot)
void	AccessController.preLockHeartbeat(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, String description)
void	AccessController.preMergeRegions(ObserverContext<MasterCoprocessorEnvironment> ctx, RegionInfo[] regionsToMerge)
void	AccessController.preModifyNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx, NamespaceDescriptor ns)
void	CoprocessorWhitelistMasterObserver.preModifyTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, TableDescriptor htd)
void	AccessController.preModifyTable(ObserverContext<MasterCoprocessorEnvironment> c, TableName tableName, TableDescriptor htd)
void	AccessController.preMove(ObserverContext<MasterCoprocessorEnvironment> c, RegionInfo region, ServerName srcServer, ServerName destServer)
void	AccessController.preOpen(ObserverContext<RegionCoprocessorEnvironment> c)
void	AccessController.prePrepareBulkLoad(ObserverContext<RegionCoprocessorEnvironment> ctx) Authorization check for SecureBulkLoadProtocol.prepareBulkLoad()
void	AccessController.prePut(ObserverContext<RegionCoprocessorEnvironment> c, Put put, WALEdit edit, Durability durability)
void	AccessController.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.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.preRollWALWriterRequest(ObserverContext<RegionServerCoprocessorEnvironment> ctx)
void	AccessController.preScannerClose(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s)
boolean	AccessController.preScannerNext(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s, List<Result> result, int limit, boolean hasNext)
void	AccessController.preScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Scan scan)
void	AccessController.preSetNamespaceQuota(ObserverContext<MasterCoprocessorEnvironment> ctx, String namespace, 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, GlobalQuotaSettings quotas)
void	AccessController.preSetUserQuota(ObserverContext<MasterCoprocessorEnvironment> ctx, String userName, String namespace, 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	AccessController.preStopRegionServer(ObserverContext<RegionServerCoprocessorEnvironment> ctx)
void	AccessController.preTableFlush(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName)
void	AccessController.preTruncateTable(ObserverContext<MasterCoprocessorEnvironment> c, TableName tableName)
void	AccessController.preUnassign(ObserverContext<MasterCoprocessorEnvironment> c, RegionInfo regionInfo, boolean force)
void	AccessController.preUpdateReplicationPeerConfig(ObserverContext<MasterCoprocessorEnvironment> ctx, String peerId, ReplicationPeerConfig peerConfig)
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

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

Modifier and Type	Method and Description
ReplicationEndpoint	VisibilityReplication.postCreateReplicationEndPoint(ObserverContext<RegionServerCoprocessorEnvironment> ctx, ReplicationEndpoint endpoint)
DeleteTracker	VisibilityController.postInstantiateDeleteTracker(ObserverContext<RegionCoprocessorEnvironment> ctx, DeleteTracker delTracker)
Cell	VisibilityController.postMutationBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx, RegionObserver.MutationType opType, Mutation mutation, Cell oldCell, Cell newCell)
void	VisibilityController.postOpen(ObserverContext<RegionCoprocessorEnvironment> e) Region related hooks
void	VisibilityController.postScannerClose(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s)
boolean	VisibilityController.postScannerFilterRow(ObserverContext<RegionCoprocessorEnvironment> e, InternalScanner s, Cell curRowCell, boolean hasMore)
RegionScanner	VisibilityController.postScannerOpen(ObserverContext<RegionCoprocessorEnvironment> c, Scan scan, RegionScanner s)
void	VisibilityController.postSetSplitOrMergeEnabled(ObserverContext<MasterCoprocessorEnvironment> ctx, boolean newValue, MasterSwitchType switchType)
void	VisibilityController.postStartMaster(ObserverContext<MasterCoprocessorEnvironment> ctx) Master related hooks
Result	VisibilityController.preAppend(ObserverContext<RegionCoprocessorEnvironment> e, Append append)
void	VisibilityController.preBatchMutate(ObserverContext<RegionCoprocessorEnvironment> c, MiniBatchOperationInProgress<Mutation> miniBatchOp)
void	VisibilityController.preDisableTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName)
void	VisibilityController.preGetOp(ObserverContext<RegionCoprocessorEnvironment> e, Get get, List<Cell> results)
Result	VisibilityController.preIncrement(ObserverContext<RegionCoprocessorEnvironment> e, Increment increment)
void	VisibilityController.preModifyTable(ObserverContext<MasterCoprocessorEnvironment> ctx, TableName tableName, TableDescriptor htd)
void	VisibilityController.prePrepareTimeStampForDeleteVersion(ObserverContext<RegionCoprocessorEnvironment> ctx, Mutation delete, Cell cell, byte[] byteNow, Get get)
void	VisibilityController.preScannerClose(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s)
boolean	VisibilityController.preScannerNext(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s, List<Result> result, int limit, boolean hasNext)
void	VisibilityController.preScannerOpen(ObserverContext<RegionCoprocessorEnvironment> e, Scan scan)

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

Methods in org.apache.hadoop.hbase.tool with parameters of type ObserverContext

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