@InterfaceAudience.Private public interface RegionServerServices extends Server, MutableOnlineRegions, FavoredNodesForRegion
HRegionServer
. For use internally only. Passed
to Managers, Services and Chores so can pass less-than-a full-on HRegionServer at test-time. Be
judicious adding API. Changes cause ripples through the code base.Modifier and Type | Interface and Description |
---|---|
static class |
RegionServerServices.PostOpenDeployContext
Context for postOpenDeployTasks().
|
static class |
RegionServerServices.RegionStateTransitionContext |
createConnection, getAsyncClusterConnection, getAsyncConnection, getChoreService, getConfiguration, getConnection, getCoordinatedStateManager, getFileSystem, getServerName, getZooKeeper, isStopping
addRegion, removeRegion
getFavoredNodesForRegion, updateRegionFavoredNodesMapping
WAL getWAL(RegionInfo regionInfo) throws IOException
IOException
List<WAL> getWALs() throws IOException
IOException
FlushRequester getFlushRequester()
FlushRequester
or null. Usually it will not be null unless
during intialization.CompactionRequester getCompactionRequestor()
CompactionRequester
or null. Usually it will not be null
unless during intialization.RegionServerAccounting getRegionServerAccounting()
RegionServerRpcQuotaManager getRegionServerRpcQuotaManager()
RegionServerRpcQuotaManager
SecureBulkLoadManager getSecureBulkLoadManager()
SecureBulkLoadManager
RegionServerSpaceQuotaManager getRegionServerSpaceQuotaManager()
RegionServerSpaceQuotaManager
void postOpenDeployTasks(RegionServerServices.PostOpenDeployContext context) throws IOException
context
- the contextIOException
boolean reportRegionStateTransition(RegionServerServices.RegionStateTransitionContext context)
RpcServerInterface getRpcServer()
ConcurrentMap<byte[],Boolean> getRegionsInTransitionInRS()
LeaseManager getLeaseManager()
ExecutorService getExecutorService()
ServerNonceManager getNonceManager()
boolean registerService(org.apache.hbase.thirdparty.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()
ThroughputController getFlushThroughputController()
@Deprecated double getFlushPressure()
MetricsRegionServer getMetrics()
EntityLock regionLock(List<RegionInfo> regionInfos, String description, Abortable abort) throws IOException
IOException
void unassign(byte[] regionName) throws IOException
See HBASE-17712 for more details.
IOException
boolean reportRegionSizesForQuotas(RegionSizeStore sizeStore)
sizeStore
- The sizes for Regions locally hosted.false
if reporting should be temporarily paused, true
otherwise.boolean reportFileArchivalForQuotas(TableName tableName, Collection<Map.Entry<String,Long>> archivedFiles)
table
were
just moved to the archive directory.tableName
- The name of the table that files previously belonged toarchivedFiles
- Files and their sizes that were moved to archivetrue
if the files were successfully reported, false
otherwise.boolean isClusterUp()
ReplicationSourceService getReplicationSourceService()
TableDescriptors getTableDescriptors()
Optional<BlockCache> getBlockCache()
Optional<MobFileCache> getMobFileCache()
AccessChecker getAccessChecker()
AccessChecker
ZKPermissionWatcher getZKPermissionWatcher()
ZKPermissionWatcher
RegionReplicationBufferManager getRegionReplicationBufferManager()
HRegion getRegion(String encodedRegionName)
OnlineRegions
Region
instance. Only works if caller is in same context, in same JVM. Region is
not serializable. n * @return Region for the passed encoded encodedRegionName
or
null if named region is not member of the online regions.getRegion
in interface OnlineRegions
List<HRegion> getRegions(TableName tableName) throws IOException
OnlineRegions
getRegions
in interface OnlineRegions
IOException
List<HRegion> getRegions()
OnlineRegions
getRegions
in interface OnlineRegions
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.