@InterfaceAudience.LimitedPrivate(value="Coprocesssor") @InterfaceStability.Evolving public interface RegionServerServices extends OnlineRegions, FavoredNodesForRegion
HRegionServer
Modifier and Type | Interface and Description |
---|---|
static class |
RegionServerServices.PostOpenDeployContext
Context for postOpenDeployTasks().
|
static class |
RegionServerServices.RegionStateTransitionContext |
Modifier and Type | Method and Description |
---|---|
double |
getCompactionPressure() |
CompactionRequestor |
getCompactionRequester() |
ExecutorService |
getExecutorService() |
org.apache.hadoop.fs.FileSystem |
getFileSystem() |
FlushRequester |
getFlushRequester() |
HeapMemoryManager |
getHeapMemoryManager() |
Leases |
getLeases() |
ServerNonceManager |
getNonceManager()
Only required for "old" log replay; if it's removed, remove this.
|
Set<TableName> |
getOnlineTables() |
Map<String,Region> |
getRecoveringRegions() |
RegionServerAccounting |
getRegionServerAccounting() |
RegionServerQuotaManager |
getRegionServerQuotaManager() |
ConcurrentMap<byte[],Boolean> |
getRegionsInTransitionInRS()
Get the regions that are currently being opened or closed in the RS
|
RpcServerInterface |
getRpcServer()
Returns a reference to the region server's RPC server
|
TableLockManager |
getTableLockManager() |
WAL |
getWAL(HRegionInfo regionInfo) |
boolean |
isStopping() |
void |
postOpenDeployTasks(Region r)
Deprecated.
|
void |
postOpenDeployTasks(RegionServerServices.PostOpenDeployContext context)
Tasks to perform after region open to complete deploy of region on
regionserver
|
boolean |
registerService(com.google.protobuf.Service service)
Registers a new protocol buffer
Service subclass as a coprocessor endpoint to be
available for handling |
boolean |
reportRegionStateTransition(RegionServerServices.RegionStateTransitionContext context)
Notify master that a handler requests to change a region state
|
boolean |
reportRegionStateTransition(org.apache.hadoop.hbase.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode code,
HRegionInfo... hris)
Deprecated.
|
boolean |
reportRegionStateTransition(org.apache.hadoop.hbase.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode code,
long openSeqNum,
HRegionInfo... hris)
Deprecated.
|
addToOnlineRegions, getFromOnlineRegions, getOnlineRegions, removeFromOnlineRegions
getChoreService, getConfiguration, getConnection, getCoordinatedStateManager, getMetaTableLocator, getServerName, getZooKeeper
getFavoredNodesForRegion, updateRegionFavoredNodesMapping
boolean isStopping()
WAL getWAL(HRegionInfo regionInfo) throws IOException
IOException
CompactionRequestor getCompactionRequester()
CompactionRequestor
or null.FlushRequester getFlushRequester()
FlushRequester
or null.RegionServerAccounting getRegionServerAccounting()
TableLockManager getTableLockManager()
TableLockManager
RegionServerQuotaManager getRegionServerQuotaManager()
RegionServerQuotaManager
void postOpenDeployTasks(RegionServerServices.PostOpenDeployContext context) throws org.apache.zookeeper.KeeperException, IOException
context
- the contextorg.apache.zookeeper.KeeperException
IOException
@Deprecated void postOpenDeployTasks(Region r) throws org.apache.zookeeper.KeeperException, IOException
postOpenDeployTasks(PostOpenDeployContext)
r
- Region to open.org.apache.zookeeper.KeeperException
IOException
boolean reportRegionStateTransition(RegionServerServices.RegionStateTransitionContext context)
@Deprecated boolean reportRegionStateTransition(org.apache.hadoop.hbase.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode code, long openSeqNum, HRegionInfo... hris)
reportRegionStateTransition(RegionStateTransitionContext)
@Deprecated boolean reportRegionStateTransition(org.apache.hadoop.hbase.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode code, HRegionInfo... hris)
reportRegionStateTransition(RegionStateTransitionContext)
RpcServerInterface getRpcServer()
ConcurrentMap<byte[],Boolean> getRegionsInTransitionInRS()
org.apache.hadoop.fs.FileSystem getFileSystem()
Leases getLeases()
ExecutorService getExecutorService()
Map<String,Region> getRecoveringRegions()
ServerNonceManager getNonceManager()
boolean registerService(com.google.protobuf.Service service)
Service
subclass as a coprocessor endpoint to be
available for handlingservice
- the Service
subclass instance to expose as a coprocessor endpointtrue
if the registration was successful, false
HeapMemoryManager getHeapMemoryManager()
double getCompactionPressure()
Store.getCompactionPressure()
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.