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 |
Modifier and Type | Method and Description |
---|---|
void |
ConstraintProcessor.prePut(ObserverContext<RegionCoprocessorEnvironment> e,
Put put,
WALEdit edit,
Durability durability) |
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. |
Modifier and Type | Method and Description |
---|---|
static <E extends CoprocessorEnvironment> |
ObserverContextImpl.createAndPrepare(E env)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
private boolean |
MetaTableMetrics.ExampleRegionObserverMeta.isMetaTableOp(ObserverContext<RegionCoprocessorEnvironment> e) |
default void |
MasterObserver.postAbortProcedure(ObserverContext<MasterCoprocessorEnvironment> ctx)
Called after a abortProcedure request has been processed.
|
default void |
MasterObserver.postAddReplicationPeer(ObserverContext<MasterCoprocessorEnvironment> ctx,
String peerId,
ReplicationPeerConfig peerConfig)
Called after add a replication 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)
Deprecated.
since 2.5.0 and will be removed in 4.0.0. Use
RegionObserver.postAppend(ObserverContext, Append, Result, WALEdit) instead. |
default Result |
RegionObserver.postAppend(ObserverContext<RegionCoprocessorEnvironment> c,
Append append,
Result result,
WALEdit edit)
Called after Append
|
default List<Pair<Cell,Cell>> |
RegionObserver.postAppendBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx,
Mutation mutation,
List<Pair<Cell,Cell>> cellPairs)
Called after a list of new cells has been created during an append operation, but before they
are committed to the WAL or memstore.
|
default void |
MasterObserver.postAssign(ObserverContext<MasterCoprocessorEnvironment> ctx,
RegionInfo regionInfo)
Called after the region assignment has been requested.
|
default void |
MasterObserver.postBalance(ObserverContext<MasterCoprocessorEnvironment> ctx,
BalanceRequest request,
List<RegionPlan> plans)
Called after the balancing plan has been submitted.
|
default void |
MasterObserver.postBalanceRSGroup(ObserverContext<MasterCoprocessorEnvironment> ctx,
String groupName,
BalanceRequest request,
BalanceResponse response)
Called after a region server group is 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/increment/append and will be called even if the
batch operation fails.
|
default void |
RegionObserver.postBulkLoadHFile(ObserverContext<RegionCoprocessorEnvironment> ctx,
List<Pair<byte[],String>> stagingFamilyPaths,
Map<byte[],List<org.apache.hadoop.fs.Path>> finalPaths)
Called after bulkLoadHFile.
|
default boolean |
RegionObserver.postCheckAndDelete(ObserverContext<RegionCoprocessorEnvironment> c,
byte[] row,
byte[] family,
byte[] qualifier,
CompareOperator op,
ByteArrayComparable comparator,
Delete delete,
boolean result)
Deprecated.
since 2.4.0 and will be removed in 4.0.0. Use
RegionObserver.postCheckAndMutate(ObserverContext, CheckAndMutate, CheckAndMutateResult)
instead. |
default boolean |
RegionObserver.postCheckAndDelete(ObserverContext<RegionCoprocessorEnvironment> c,
byte[] row,
Filter filter,
Delete delete,
boolean result)
Deprecated.
since 2.4.0 and will be removed in 4.0.0. Use
RegionObserver.postCheckAndMutate(ObserverContext, CheckAndMutate, CheckAndMutateResult)
instead. |
default CheckAndMutateResult |
RegionObserver.postCheckAndMutate(ObserverContext<RegionCoprocessorEnvironment> c,
CheckAndMutate checkAndMutate,
CheckAndMutateResult result)
Called after checkAndMutate
|
default boolean |
RegionObserver.postCheckAndPut(ObserverContext<RegionCoprocessorEnvironment> c,
byte[] row,
byte[] family,
byte[] qualifier,
CompareOperator op,
ByteArrayComparable comparator,
Put put,
boolean result)
Deprecated.
since 2.4.0 and will be removed in 4.0.0. Use
RegionObserver.postCheckAndMutate(ObserverContext, CheckAndMutate, CheckAndMutateResult)
instead. |
default boolean |
RegionObserver.postCheckAndPut(ObserverContext<RegionCoprocessorEnvironment> c,
byte[] row,
Filter filter,
Put put,
boolean result)
Deprecated.
since 2.4.0 and will be removed in 4.0.0. Use
RegionObserver.postCheckAndMutate(ObserverContext, CheckAndMutate, CheckAndMutateResult)
instead. |
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
StoreFile s to compact have been selected from the available
candidates. |
default void |
MasterObserver.postCompletedCreateTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableDescriptor desc,
RegionInfo[] regions)
Called after the createTable operation has been requested.
|
default void |
MasterObserver.postCompletedDeleteTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName)
Called 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.postCompletedSnapshotAction(ObserverContext<MasterCoprocessorEnvironment> ctx,
SnapshotDescription snapshot,
TableDescriptor tableDescriptor)
Called after the snapshot operation has been completed.
|
default void |
MasterObserver.postCompletedSplitRegionAction(ObserverContext<MasterCoprocessorEnvironment> c,
RegionInfo regionInfoA,
RegionInfo regionInfoB)
Called after the region is split.
|
default void |
MasterObserver.postCompletedTruncateTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName)
Called 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)
Called after the client deletes a value.
|
default void |
RegionObserver.postDelete(ObserverContext<RegionCoprocessorEnvironment> c,
Delete delete,
WALEdit edit,
Durability durability)
Deprecated.
since 2.5.0 and will be removed in 4.0.0. Use
RegionObserver.postDelete(ObserverContext, Delete, WALEdit) instead. |
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 n * @param peerId a short name that identifies the 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 n * @param peerId a short name that identifies the 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 void |
RegionServerObserver.postExecuteProcedures(ObserverContext<RegionServerCoprocessorEnvironment> ctx)
This will be called after executing procedures
|
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 n * @param peerId
a short name that identifies the 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 void |
MasterObserver.postGetUserPermissions(ObserverContext<MasterCoprocessorEnvironment> ctx,
String userName,
String namespace,
TableName tableName,
byte[] family,
byte[] qualifier)
Called after getting user permissions.
|
default void |
MasterObserver.postGrant(ObserverContext<MasterCoprocessorEnvironment> ctx,
UserPermission userPermission,
boolean mergeExistingPermissions)
Called after granting user permissions.
|
default void |
MasterObserver.postHasUserPermissions(ObserverContext<MasterCoprocessorEnvironment> ctx,
String userName,
List<Permission> permissions)
Called after checking if user has permissions.
|
default Result |
RegionObserver.postIncrement(ObserverContext<RegionCoprocessorEnvironment> c,
Increment increment,
Result result)
Deprecated.
since 2.5.0 and will be removed in 4.0.0. Use
RegionObserver.postIncrement(ObserverContext, Increment, Result, WALEdit) instead. |
default Result |
RegionObserver.postIncrement(ObserverContext<RegionCoprocessorEnvironment> c,
Increment increment,
Result result,
WALEdit edit)
Called after increment
|
default List<Pair<Cell,Cell>> |
RegionObserver.postIncrementBeforeWAL(ObserverContext<RegionCoprocessorEnvironment> ctx,
Mutation mutation,
List<Pair<Cell,Cell>> cellPairs)
Called after a list of new cells has been created during an increment operation, but before
they are committed to the WAL or memstore.
|
default DeleteTracker |
RegionObserver.postInstantiateDeleteTracker(ObserverContext<RegionCoprocessorEnvironment> ctx,
DeleteTracker delTracker)
Deprecated.
Since 2.0 with out any replacement and will be removed in 3.0
|
default void |
MasterObserver.postIsRpcThrottleEnabled(ObserverContext<MasterCoprocessorEnvironment> ctx,
boolean rpcThrottleEnabled)
Called after getting if is rpc throttle enabled.
|
default void |
MasterObserver.postListDecommissionedRegionServers(ObserverContext<MasterCoprocessorEnvironment> ctx)
Called after list decommissioned region servers.
|
default void |
MasterObserver.postListNamespaceDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx,
List<NamespaceDescriptor> descriptors)
Called after a listNamespaceDescriptors request has been processed.
|
default void |
MasterObserver.postListNamespaces(ObserverContext<MasterCoprocessorEnvironment> ctx,
List<String> namespaces)
Called after a listNamespaces request has been processed.
|
default void |
MasterObserver.postListReplicationPeers(ObserverContext<MasterCoprocessorEnvironment> ctx,
String regex)
Called after list replication peers.
|
default void |
MasterObserver.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 |
MasterObserver.postMasterStoreFlush(ObserverContext<MasterCoprocessorEnvironment> ctx)
Called after the master local region memstore is flushed to disk.
|
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.postModifyColumnFamilyStoreFileTracker(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName,
byte[] family,
String dstSFT)
Called after modifying a family store file tracker.
|
default void |
MasterObserver.postModifyNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx,
NamespaceDescriptor 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.postModifyTableStoreFileTracker(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName,
String dstSFT)
Called after modifying a table's store file tracker.
|
default void |
MasterObserver.postMove(ObserverContext<MasterCoprocessorEnvironment> ctx,
RegionInfo region,
ServerName srcServer,
ServerName destServer)
Called after the region move has been requested.
|
default void |
MasterObserver.postMoveServers(ObserverContext<MasterCoprocessorEnvironment> ctx,
Set<Address> servers,
String targetGroup)
Called after servers are moved to target region server 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)
Deprecated.
since 2.2.0 and will be removedin 4.0.0. Use
RegionObserver.postIncrementBeforeWAL(ObserverContext, Mutation, List) or
RegionObserver.postAppendBeforeWAL(ObserverContext, Mutation, List) instead. |
default void |
RegionObserver.postOpen(ObserverContext<RegionCoprocessorEnvironment> c)
Called after the region is reported as open to the master.
|
default void |
RegionObserver.postPut(ObserverContext<RegionCoprocessorEnvironment> c,
Put put,
WALEdit edit)
Called after the client stores a value.
|
default void |
RegionObserver.postPut(ObserverContext<RegionCoprocessorEnvironment> c,
Put put,
WALEdit edit,
Durability durability)
Deprecated.
since 2.5.0 and will be removed in 4.0.0. Use
RegionObserver.postPut(ObserverContext, Put, WALEdit) instead. |
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 n * @param peerId a short name that identifies the 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 |
MasterObserver.postRenameRSGroup(ObserverContext<MasterCoprocessorEnvironment> ctx,
String oldName,
String newName)
Called after rename rsgroup.
|
default void |
RegionObserver.postReplayWALs(ObserverContext<? extends RegionCoprocessorEnvironment> ctx,
RegionInfo info,
org.apache.hadoop.fs.Path edits)
Called after replaying WALs for this region.
|
default void |
RegionServerObserver.postReplicateLogEntries(ObserverContext<RegionServerCoprocessorEnvironment> ctx)
Deprecated.
As of release 2.0.0 with out any replacement. 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.postRevoke(ObserverContext<MasterCoprocessorEnvironment> ctx,
UserPermission userPermission)
Called after revoking user permissions.
|
default void |
MasterObserver.postRollBackMergeRegionsAction(ObserverContext<MasterCoprocessorEnvironment> ctx,
RegionInfo[] regionsToMerge)
This will be called after the roll back of the regions merge.
|
default void |
MasterObserver.postRollBackSplitRegionAction(ObserverContext<MasterCoprocessorEnvironment> ctx)
This will be called after the roll back of the split region is 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.postSetRegionServerQuota(ObserverContext<MasterCoprocessorEnvironment> ctx,
String regionServer,
GlobalQuotaSettings quotas)
Called after the quota for the region server is stored.
|
default void |
MasterObserver.postSetSplitOrMergeEnabled(ObserverContext<MasterCoprocessorEnvironment> ctx,
boolean newValue,
MasterSwitchType switchType)
Called after setting split / merge 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.postSwitchExceedThrottleQuota(ObserverContext<MasterCoprocessorEnvironment> ctx,
boolean oldValue,
boolean newValue)
Called after switching exceed throttle quota state.
|
default void |
MasterObserver.postSwitchRpcThrottle(ObserverContext<MasterCoprocessorEnvironment> ctx,
boolean oldValue,
boolean newValue)
Called after switching rpc throttle enabled state.
|
default void |
MasterObserver.postTableFlush(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName)
Called after the table memstore is flushed to disk.
|
default void |
MasterObserver.postTruncateTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName)
Called after the truncateTable operation has been requested.
|
default void |
MasterObserver.postUnassign(ObserverContext<MasterCoprocessorEnvironment> ctx,
RegionInfo regionInfo)
Called after the region unassignment has been requested.
|
default void |
MasterObserver.postUnassign(ObserverContext<MasterCoprocessorEnvironment> ctx,
RegionInfo regionInfo,
boolean force)
Deprecated.
in 2.4.0. replaced by postUnassign(ctx, regionInfo). removed in hbase 3. until then
safe to either leave implementation here or move it to the new method. default impl
of that method calls this one.
|
default void |
MasterObserver.postUpdateReplicationPeerConfig(ObserverContext<MasterCoprocessorEnvironment> ctx,
String peerId,
ReplicationPeerConfig peerConfig)
Called after update peerConfig for the specified peer
|
default void |
MasterObserver.postUpdateRSGroupConfig(ObserverContext<MasterCoprocessorEnvironment> ctx,
String groupName,
Map<String,String> configuration)
Called after update rsgroup config.
|
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)
Deprecated.
since 2.5.0 and will be removed in 4.0.0. Use
RegionObserver.preAppend(ObserverContext, Append, WALEdit) instead. |
default Result |
RegionObserver.preAppend(ObserverContext<RegionCoprocessorEnvironment> c,
Append append,
WALEdit edit)
Called before Append.
|
default Result |
RegionObserver.preAppendAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c,
Append append)
Deprecated.
since 2.5.0 and will be removed in 4.0.0. Use
RegionObserver.preBatchMutate(ObserverContext, MiniBatchOperationInProgress) instead. |
default void |
MasterObserver.preAssign(ObserverContext<MasterCoprocessorEnvironment> ctx,
RegionInfo regionInfo)
Called prior to assigning a specific region.
|
default void |
MasterObserver.preBalance(ObserverContext<MasterCoprocessorEnvironment> ctx,
BalanceRequest request)
Called prior to requesting rebalancing of the cluster regions, though after the initial checks
for regions in transition and the balance switch flag.
|
default void |
MasterObserver.preBalanceRSGroup(ObserverContext<MasterCoprocessorEnvironment> ctx,
String groupName,
BalanceRequest request)
Called before a region server group is 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)
Deprecated.
since 2.4.0 and will be removed in 4.0.0. Use
RegionObserver.preCheckAndMutate(ObserverContext, CheckAndMutate, CheckAndMutateResult)
instead. |
default boolean |
RegionObserver.preCheckAndDelete(ObserverContext<RegionCoprocessorEnvironment> c,
byte[] row,
Filter filter,
Delete delete,
boolean result)
Deprecated.
since 2.4.0 and will be removed in 4.0.0. Use
RegionObserver.preCheckAndMutate(ObserverContext, CheckAndMutate, CheckAndMutateResult)
instead. |
default boolean |
RegionObserver.preCheckAndDeleteAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c,
byte[] row,
byte[] family,
byte[] qualifier,
CompareOperator op,
ByteArrayComparable comparator,
Delete delete,
boolean result)
Deprecated.
since 2.4.0 and will be removed in 4.0.0. Use
RegionObserver.preCheckAndMutateAfterRowLock(ObserverContext, CheckAndMutate,CheckAndMutateResult)
instead. |
default boolean |
RegionObserver.preCheckAndDeleteAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c,
byte[] row,
Filter filter,
Delete delete,
boolean result)
Deprecated.
since 2.4.0 and will be removed in 4.0.0. Use
RegionObserver.preCheckAndMutateAfterRowLock(ObserverContext, CheckAndMutate,CheckAndMutateResult)
instead. |
default CheckAndMutateResult |
RegionObserver.preCheckAndMutate(ObserverContext<RegionCoprocessorEnvironment> c,
CheckAndMutate checkAndMutate,
CheckAndMutateResult result)
Called before checkAndMutate
|
default CheckAndMutateResult |
RegionObserver.preCheckAndMutateAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c,
CheckAndMutate checkAndMutate,
CheckAndMutateResult result)
Called before checkAndDelete but after acquiring rowlock.
|
default boolean |
RegionObserver.preCheckAndPut(ObserverContext<RegionCoprocessorEnvironment> c,
byte[] row,
byte[] family,
byte[] qualifier,
CompareOperator op,
ByteArrayComparable comparator,
Put put,
boolean result)
Deprecated.
since 2.4.0 and will be removed in 4.0.0. Use
RegionObserver.preCheckAndMutate(ObserverContext, CheckAndMutate, CheckAndMutateResult)
instead. |
default boolean |
RegionObserver.preCheckAndPut(ObserverContext<RegionCoprocessorEnvironment> c,
byte[] row,
Filter filter,
Put put,
boolean result)
Deprecated.
since 2.4.0 and will be removed in 4.0.0. Use
RegionObserver.preCheckAndMutate(ObserverContext, CheckAndMutate, CheckAndMutateResult)
instead. |
default boolean |
RegionObserver.preCheckAndPutAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c,
byte[] row,
byte[] family,
byte[] qualifier,
CompareOperator op,
ByteArrayComparable comparator,
Put put,
boolean result)
Deprecated.
since 2.4.0 and will be removed in 4.0.0. Use
RegionObserver.preCheckAndMutateAfterRowLock(ObserverContext, CheckAndMutate,CheckAndMutateResult)
instead. |
default boolean |
RegionObserver.preCheckAndPutAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c,
byte[] row,
Filter filter,
Put put,
boolean result)
Deprecated.
since 2.4.0 and will be removed in 4.0.0. Use
RegionObserver.preCheckAndMutateAfterRowLock(ObserverContext, CheckAndMutate,CheckAndMutateResult)
instead. |
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
StoreFile s 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 TableDescriptor |
MasterObserver.preCreateTableRegionsInfos(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableDescriptor desc)
Called before we create the region infos for this table.
|
default void |
MasterObserver.preDecommissionRegionServers(ObserverContext<MasterCoprocessorEnvironment> ctx,
List<ServerName> servers,
boolean offload)
Called before decommission region servers.
|
default void |
RegionObserver.preDelete(ObserverContext<RegionCoprocessorEnvironment> c,
Delete delete,
WALEdit edit)
Called before the client deletes a value.
|
default void |
RegionObserver.preDelete(ObserverContext<RegionCoprocessorEnvironment> c,
Delete delete,
WALEdit edit,
Durability durability)
Deprecated.
since 2.5.0 and will be removed in 4.0.0. Use
RegionObserver.preDelete(ObserverContext, Delete, WALEdit) instead. |
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 n * @param peerId a short name that identifies the
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 n * @param peerId a short name that identifies the 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 void |
RegionServerObserver.preExecuteProcedures(ObserverContext<RegionServerCoprocessorEnvironment> ctx)
This will be called before executing procedures
|
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 n * @param peerId
a short name that identifies the 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 void |
MasterObserver.preGetUserPermissions(ObserverContext<MasterCoprocessorEnvironment> ctx,
String userName,
String namespace,
TableName tableName,
byte[] family,
byte[] qualifier)
Called before getting user permissions.
|
default void |
MasterObserver.preGrant(ObserverContext<MasterCoprocessorEnvironment> ctx,
UserPermission userPermission,
boolean mergeExistingPermissions)
Called before granting user permissions.
|
default void |
MasterObserver.preHasUserPermissions(ObserverContext<MasterCoprocessorEnvironment> ctx,
String userName,
List<Permission> permissions) |
default Result |
RegionObserver.preIncrement(ObserverContext<RegionCoprocessorEnvironment> c,
Increment increment)
Deprecated.
since 2.5.0 and will be removed in 4.0.0. Use
RegionObserver.preIncrement(ObserverContext, Increment, WALEdit) instead. |
default Result |
RegionObserver.preIncrement(ObserverContext<RegionCoprocessorEnvironment> c,
Increment increment,
WALEdit edit)
Called before Increment.
|
default Result |
RegionObserver.preIncrementAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c,
Increment increment)
Deprecated.
since 2.5.0 and will be removed in 4.0.0. Use
RegionObserver.preBatchMutate(ObserverContext, MiniBatchOperationInProgress) instead. |
default void |
MasterObserver.preIsRpcThrottleEnabled(ObserverContext<MasterCoprocessorEnvironment> ctx)
Called before getting if is rpc throttle enabled.
|
default void |
MasterObserver.preListDecommissionedRegionServers(ObserverContext<MasterCoprocessorEnvironment> ctx)
Called before list decommissioned region servers.
|
default void |
MasterObserver.preListNamespaceDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx,
List<NamespaceDescriptor> descriptors)
Called before a listNamespaceDescriptors request has been processed.
|
default void |
MasterObserver.preListNamespaces(ObserverContext<MasterCoprocessorEnvironment> ctx,
List<String> namespaces)
Called before a listNamespaces request has been processed.
|
default void |
MasterObserver.preListReplicationPeers(ObserverContext<MasterCoprocessorEnvironment> ctx,
String regex)
Called before list replication peers.
|
default void |
MasterObserver.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 |
MasterObserver.preMasterStoreFlush(ObserverContext<MasterCoprocessorEnvironment> ctx)
Called before the master local region memstore is flushed to disk.
|
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 String |
MasterObserver.preModifyColumnFamilyStoreFileTracker(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName,
byte[] family,
String dstSFT)
Called prior to modifying a family's store file tracker.
|
default void |
MasterObserver.preModifyNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx,
NamespaceDescriptor 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 TableDescriptor |
MasterObserver.preModifyTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName,
TableDescriptor currentDescriptor,
TableDescriptor newDescriptor)
Called prior to modifying a table's properties.
|
default void |
MasterObserver.preModifyTableAction(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName,
TableDescriptor 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 String |
MasterObserver.preModifyTableStoreFileTracker(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName,
String dstSFT)
Called prior to modifying a table's store file tracker.
|
default void |
MasterObserver.preMove(ObserverContext<MasterCoprocessorEnvironment> ctx,
RegionInfo region,
ServerName srcServer,
ServerName destServer)
Called prior to moving a given region from one region server to another.
|
default void |
MasterObserver.preMoveServers(ObserverContext<MasterCoprocessorEnvironment> ctx,
Set<Address> servers,
String targetGroup)
Called before servers are moved to target region server 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)
Called before the client stores a value.
|
default void |
RegionObserver.prePut(ObserverContext<RegionCoprocessorEnvironment> c,
Put put,
WALEdit edit,
Durability durability)
Deprecated.
since 2.5.0 and will be removed in 4.0.0. Use
RegionObserver.prePut(ObserverContext, Put, WALEdit) instead. |
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 n * @param peerId a short name that identifies the 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 |
MasterObserver.preRenameRSGroup(ObserverContext<MasterCoprocessorEnvironment> ctx,
String oldName,
String newName)
Called before rename rsgroup.
|
default void |
RegionObserver.preReplayWALs(ObserverContext<? extends RegionCoprocessorEnvironment> ctx,
RegionInfo info,
org.apache.hadoop.fs.Path edits)
Called before replaying WALs for this region.
|
default void |
RegionServerObserver.preReplicateLogEntries(ObserverContext<RegionServerCoprocessorEnvironment> ctx)
Deprecated.
As of release 2.0.0 with out any replacement. 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 |
MasterObserver.preRevoke(ObserverContext<MasterCoprocessorEnvironment> ctx,
UserPermission userPermission)
Called before revoking user permissions.
|
default void |
RegionServerObserver.preRollWALWriterRequest(ObserverContext<RegionServerCoprocessorEnvironment> ctx)
This will be called before executing user request to roll a region server WAL.
|
default void |
RegionObserver.preScannerClose(ObserverContext<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.preSetRegionServerQuota(ObserverContext<MasterCoprocessorEnvironment> ctx,
String regionServer,
GlobalQuotaSettings quotas)
Called before the quota for the region server is stored.
|
default void |
MasterObserver.preSetSplitOrMergeEnabled(ObserverContext<MasterCoprocessorEnvironment> ctx,
boolean newValue,
MasterSwitchType switchType)
Called prior to setting split / merge switch Supports Coprocessor 'bypass'.
|
default void |
MasterObserver.preSetTableQuota(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName,
GlobalQuotaSettings quotas)
Called before the quota for the table is stored.
|
default void |
MasterObserver.preSetUserQuota(ObserverContext<MasterCoprocessorEnvironment> ctx,
String userName,
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.preSwitchExceedThrottleQuota(ObserverContext<MasterCoprocessorEnvironment> ctx,
boolean enable)
Called before switching exceed throttle quota state.
|
default void |
MasterObserver.preSwitchRpcThrottle(ObserverContext<MasterCoprocessorEnvironment> ctx,
boolean enable)
Called before switching rpc throttle enabled state.
|
default void |
MasterObserver.preTableFlush(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName)
Called before the table memstore is flushed to disk.
|
default void |
MasterObserver.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)
Called prior to unassigning a given region.
|
default void |
MasterObserver.preUnassign(ObserverContext<MasterCoprocessorEnvironment> ctx,
RegionInfo regionInfo,
boolean force)
Deprecated.
in 2.4.0. replaced by preUnassign(ctx, regionInfo). removed in hbase 3. until then
safe to either leave implementation here or move it to the new method. default impl
of that method calls this one.
|
default void |
MasterObserver.preUpdateReplicationPeerConfig(ObserverContext<MasterCoprocessorEnvironment> ctx,
String peerId,
ReplicationPeerConfig peerConfig)
Called before update peerConfig for the specified peer n * @param peerId a short name that
identifies the peer
|
default void |
MasterObserver.preUpdateRSGroupConfig(ObserverContext<MasterCoprocessorEnvironment> ctx,
String groupName,
Map<String,String> configuration)
Called before update rsgroup config.
|
default void |
RegionObserver.preWALAppend(ObserverContext<RegionCoprocessorEnvironment> ctx,
WALKey key,
WALEdit edit)
Called just before the WAL Entry is appended to the WAL.
|
default void |
RegionObserver.preWALRestore(ObserverContext<? extends RegionCoprocessorEnvironment> ctx,
RegionInfo info,
WALKey logKey,
WALEdit logEdit)
Called before 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.registerAndMarkMetrics(ObserverContext<RegionCoprocessorEnvironment> e,
Row row) |
Modifier and Type | Class and Description |
---|---|
(package private) class |
MasterCoprocessorHost.MasterObserverOperation |
Modifier and Type | Method and Description |
---|---|
void |
MasterQuotasObserver.postDeleteNamespace(ObserverContext<MasterCoprocessorEnvironment> ctx,
String namespace) |
void |
MasterQuotasObserver.postDeleteTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName) |
Modifier and Type | Class and Description |
---|---|
(package private) class |
RegionCoprocessorHost.BulkLoadObserverOperation |
(package private) class |
RegionCoprocessorHost.RegionObserverOperationWithoutResult |
(package private) class |
RegionServerCoprocessorHost.RegionServerObserverOperation |
Modifier and Type | Class and Description |
---|---|
(package private) class |
WALCoprocessorHost.WALObserverOperation |
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) |
Modifier and Type | Method and Description |
---|---|
void |
WriteSinkCoprocessor.preBatchMutate(ObserverContext<RegionCoprocessorEnvironment> c,
MiniBatchOperationInProgress<Mutation> miniBatchOp) |
void |
WriteSinkCoprocessor.preOpen(ObserverContext<RegionCoprocessorEnvironment> e) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.