Package org.apache.hadoop.hbase

Class MockRegionServerServices

java.lang.Object

org.apache.hadoop.hbase.MockRegionServerServices

All Implemented Interfaces:

Abortable, FavoredNodesForRegion, MutableOnlineRegions, OnlineRegions, RegionServerServices, Server, Stoppable

@Private
public class MockRegionServerServices
extends Object
implements RegionServerServices

Basic mock region server services. Should only be instantiated by HBaseTestingUtility.b

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.regionserver.RegionServerServices

RegionServerServices.PostOpenDeployContext, RegionServerServices.RegionStateTransitionContext

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	abortRequested
private final org.apache.hadoop.conf.Configuration	conf
private HFileSystem	hfs
protected static final org.slf4j.Logger	LOG
private final Map<String,HRegion>	regions
private final ConcurrentSkipListMap<byte[],Boolean>	rit
private RpcServerInterface	rpcServer
private final AtomicBoolean	running
private ServerName	serverName
private boolean	stopping
private ZKWatcher	zkw

Constructor Summary

Constructors

Constructor	Description
MockRegionServerServices()
MockRegionServerServices(org.apache.hadoop.conf.Configuration conf)
MockRegionServerServices(ZKWatcher zkw)
MockRegionServerServices(ZKWatcher zkw, ServerName serverName)

Method Summary

Modifier and Type	Method	Description
void	abort(String why, Throwable e)	Abort the server or client.
void	addRegion(HRegion r)	Add to online regions.
Connection	createConnection(org.apache.hadoop.conf.Configuration conf)
AccessChecker	getAccessChecker()	Returns the AccessChecker
AsyncClusterConnection	getAsyncClusterConnection()	Returns a reference to the servers' async cluster connection.
Optional<BlockCache>	getBlockCache()	Returns The block cache instance.
ChoreService	getChoreService()	Returns The ChoreService instance for this server
double	getCompactionPressure()
CompactionRequester	getCompactionRequestor()
org.apache.hadoop.conf.Configuration	getConfiguration()	Gets the configuration object for this server.
Connection	getConnection()	Returns a reference to the servers' connection.
CoordinatedStateManager	getCoordinatedStateManager()	Get CoordinatedStateManager instance for this server.
ExecutorService	getExecutorService()	Returns hbase executor service
InetSocketAddress[]	getFavoredNodesForRegion(String encodedRegionName)	Get the favored nodes mapping for this region.
HFileSystem	getFileSystem()	Returns Return the FileSystem object used (can return null!).
double	getFlushPressure()
FlushRequester	getFlushRequester()
ThroughputController	getFlushThroughputController()	Returns the controller to avoid flush too fast
HeapMemoryManager	getHeapMemoryManager()	Returns heap memory manager instance
LeaseManager	getLeaseManager()	Returns The RegionServer's "Leases" service
MetricsRegionServer	getMetrics()	Returns the metrics tracker for the region server
Optional<MobFileCache>	getMobFileCache()	Returns The cache for mob files.
ServerNonceManager	getNonceManager()	Only required for "old" log replay; if it's removed, remove this.
HRegion	getRegion(String encodedRegionName)	Return Region instance.
RegionReplicationBufferManager	getRegionReplicationBufferManager()
List<HRegion>	getRegions()	Get all online regions in this RS.
List<HRegion>	getRegions(TableName tableName)	Get all online regions of a table in this RS.
RegionServerAccounting	getRegionServerAccounting()	Returns the RegionServerAccounting for this Region Server
RegionServerRpcQuotaManager	getRegionServerRpcQuotaManager()	Returns RegionServer's instance of RegionServerRpcQuotaManager
RegionServerSpaceQuotaManager	getRegionServerSpaceQuotaManager()	Returns RegionServer's instance of RegionServerSpaceQuotaManager
ConcurrentSkipListMap<byte[],Boolean>	getRegionsInTransitionInRS()	Get the regions that are currently being opened or closed in the RS
ReplicationSourceService	getReplicationSourceService()	Returns Return the object that implements the replication source executorService.
RpcServerInterface	getRpcServer()	Returns a reference to the region server's RPC server
SecureBulkLoadManager	getSecureBulkLoadManager()	Returns RegionServer's instance of SecureBulkLoadManager
ServerName	getServerName()	Returns The unique server name for this server.
TableDescriptors	getTableDescriptors()	Returns Return table descriptors implementation.
WAL	getWAL(RegionInfo regionInfo)	Returns the WAL for a particular region.
List<WAL>	getWALs()	Returns the List of WALs that are used by this server Doesn't include the meta WAL
ZKPermissionWatcher	getZKPermissionWatcher()	Returns ZKPermissionWatcher
ZKWatcher	getZooKeeper()	Gets the ZooKeeper instance for this server.
boolean	isAborted()	Check if the server or client was aborted.
boolean	isClusterUp()	Returns True if cluster is up; false if cluster is not up (we are shutting down).
boolean	isStopped()	Returns True if Stoppable.stop(String) has been closed.
boolean	isStopping()	Returns True is the server is Stopping
void	postOpenDeployTasks(RegionServerServices.PostOpenDeployContext context)	Tasks to perform after region open to complete deploy of region on regionserver
EntityLock	regionLock(List<RegionInfo> regionInfos, String description, Abortable abort)	Master based locks on namespaces/tables/regions.
boolean	registerService(org.apache.hbase.thirdparty.com.google.protobuf.Service service)	Registers a new protocol buffer Service subclass as a coprocessor endpoint to be available for handling
boolean	removeRegion(HRegion r, ServerName destination)	Removes the given Region from the list of onlineRegions.
boolean	reportFileArchivalForQuotas(TableName tableName, Collection<Map.Entry<String,Long>> archivedFiles)	Reports a collection of files, and their sizes, that belonged to the given table were just moved to the archive directory.
boolean	reportRegionSizesForQuotas(RegionSizeStore sizeStore)	Reports the provided Region sizes hosted by this RegionServer to the active Master.
boolean	reportRegionStateTransition(RegionServerServices.RegionStateTransitionContext context)	Notify master that a handler requests to change a region state
void	setFileSystem(org.apache.hadoop.fs.FileSystem hfs)
void	setRpcServer(RpcServerInterface rpc)
void	stop(String why)	Stop this service.
void	unassign(byte[] regionName)	Unassign the given region from the current regionserver and assign it randomly.
void	updateRegionFavoredNodesMapping(String encodedRegionName, List<org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ServerName> favoredNodes)	Used to update the favored nodes mapping when required.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.hbase.Abortable

abort

Methods inherited from interface org.apache.hadoop.hbase.Server

getAsyncConnection

Field Details

LOG

protected static final org.slf4j.Logger LOG

regions

private final Map<String,HRegion> regions

rit

private final ConcurrentSkipListMap<byte[],Boolean> rit

hfs

private HFileSystem hfs

conf

private final org.apache.hadoop.conf.Configuration conf

zkw

private ZKWatcher zkw

serverName

private ServerName serverName

rpcServer

private RpcServerInterface rpcServer

abortRequested

private volatile boolean abortRequested

stopping

private volatile boolean stopping

running

private final AtomicBoolean running

Constructor Details

MockRegionServerServices

public MockRegionServerServices(ZKWatcher zkw)

MockRegionServerServices

public MockRegionServerServices(ZKWatcher zkw,
 ServerName serverName)

MockRegionServerServices

public MockRegionServerServices()

MockRegionServerServices

public MockRegionServerServices(org.apache.hadoop.conf.Configuration conf)

Method Details

removeRegion

public boolean removeRegion(HRegion r,
 ServerName destination)

Description copied from interface: MutableOnlineRegions

Removes the given Region from the list of onlineRegions.

Specified by:

removeRegion in interface MutableOnlineRegions

Parameters:

r - Region to remove.

destination - Destination, if any, null otherwise.

Returns:

True if we removed a region from online list.

getRegion

public HRegion getRegion(String encodedRegionName)

Description copied from interface: OnlineRegions

Return Region instance. Only works if caller is in same context, in same JVM. Region is not serializable.

Specified by:

getRegion in interface OnlineRegions

Specified by:

getRegion in interface RegionServerServices

Returns:

Region for the passed encoded encodedRegionName or null if named region is not member of the online regions.

getRegions

public List<HRegion> getRegions(TableName tableName)
                         throws IOException

Description copied from interface: OnlineRegions

Get all online regions of a table in this RS.

Specified by:

getRegions in interface OnlineRegions

Specified by:

getRegions in interface RegionServerServices

Returns:

List of Region

Throws:

IOException

getRegions

public List<HRegion> getRegions()

Description copied from interface: OnlineRegions

Get all online regions in this RS.

Specified by:

getRegions in interface OnlineRegions

Specified by:

getRegions in interface RegionServerServices

Returns:

List of online Region

addRegion

public void addRegion(HRegion r)

Description copied from interface: MutableOnlineRegions

Add to online regions.

Specified by:

addRegion in interface MutableOnlineRegions

postOpenDeployTasks

public void postOpenDeployTasks(RegionServerServices.PostOpenDeployContext context)
                         throws IOException

Description copied from interface: RegionServerServices

Tasks to perform after region open to complete deploy of region on regionserver

Specified by:

postOpenDeployTasks in interface RegionServerServices

Parameters:

context - the context

Throws:

IOException

isStopping

public boolean isStopping()

Description copied from interface: Server

Returns True is the server is Stopping

Specified by:

isStopping in interface Server

getRpcServer

public RpcServerInterface getRpcServer()

Description copied from interface: RegionServerServices

Returns a reference to the region server's RPC server

Specified by:

getRpcServer in interface RegionServerServices

setRpcServer

public void setRpcServer(RpcServerInterface rpc)

getRegionsInTransitionInRS

public ConcurrentSkipListMap<byte[],Boolean> getRegionsInTransitionInRS()

Description copied from interface: RegionServerServices

Get the regions that are currently being opened or closed in the RS

Specified by:

getRegionsInTransitionInRS in interface RegionServerServices

Returns:

map of regions in transition in this RS

getFlushRequester

public FlushRequester getFlushRequester()

Specified by:

getFlushRequester in interface RegionServerServices

Returns:

Implementation of FlushRequester or null. Usually it will not be null unless during intialization.

getCompactionRequestor

public CompactionRequester getCompactionRequestor()

Specified by:

getCompactionRequestor in interface RegionServerServices

Returns:

Implementation of CompactionRequester or null. Usually it will not be null unless during intialization.

getConnection

public Connection getConnection()

Description copied from interface: Server

Returns a reference to the servers' connection. Important note: this method returns a reference to Connection which is managed by Server itself, so callers must NOT attempt to close connection obtained.

Specified by:

getConnection in interface Server

getZooKeeper

public ZKWatcher getZooKeeper()

Description copied from interface: Server

Gets the ZooKeeper instance for this server.

Specified by:

getZooKeeper in interface Server

getCoordinatedStateManager

public CoordinatedStateManager getCoordinatedStateManager()

Description copied from interface: Server

Get CoordinatedStateManager instance for this server.

Specified by:

getCoordinatedStateManager in interface Server

getRegionServerAccounting

public RegionServerAccounting getRegionServerAccounting()

Description copied from interface: RegionServerServices

Returns the RegionServerAccounting for this Region Server

Specified by:

getRegionServerAccounting in interface RegionServerServices

getRegionServerRpcQuotaManager

public RegionServerRpcQuotaManager getRegionServerRpcQuotaManager()

Description copied from interface: RegionServerServices

Returns RegionServer's instance of RegionServerRpcQuotaManager

Specified by:

getRegionServerRpcQuotaManager in interface RegionServerServices

getServerName

public ServerName getServerName()

Description copied from interface: Server

Returns The unique server name for this server.

Specified by:

getServerName in interface Server

getConfiguration

public org.apache.hadoop.conf.Configuration getConfiguration()

Description copied from interface: Server

Gets the configuration object for this server.

Specified by:

getConfiguration in interface Server

abort

public void abort(String why,
 Throwable e)

Description copied from interface: Abortable

Abort the server or client.

Specified by:

abort in interface Abortable

Parameters:

why - Why we're aborting.

e - Throwable that caused abort. Can be null.

stop

public void stop(String why)

Description copied from interface: Stoppable

Stop this service. Implementers should favor logging errors over throwing RuntimeExceptions.

Specified by:

stop in interface Stoppable

Parameters:

why - Why we're stopping.

isStopped

public boolean isStopped()

Description copied from interface: Stoppable

Returns True if Stoppable.stop(String) has been closed.

Specified by:

isStopped in interface Stoppable

isAborted

public boolean isAborted()

Description copied from interface: Abortable

Check if the server or client was aborted.

Specified by:

isAborted in interface Abortable

Returns:

true if the server or client was aborted, false otherwise

getFileSystem

public HFileSystem getFileSystem()

Description copied from interface: Server

Returns Return the FileSystem object used (can return null!).

Specified by:

getFileSystem in interface Server

setFileSystem

public void setFileSystem(org.apache.hadoop.fs.FileSystem hfs)

getLeaseManager

public LeaseManager getLeaseManager()

Description copied from interface: RegionServerServices

Returns The RegionServer's "Leases" service

Specified by:

getLeaseManager in interface RegionServerServices

getWALs

public List<WAL> getWALs()
                  throws IOException

Description copied from interface: RegionServerServices

Returns the List of WALs that are used by this server Doesn't include the meta WAL

Specified by:

getWALs in interface RegionServerServices

Throws:

IOException

getWAL

public WAL getWAL(RegionInfo regionInfo)
           throws IOException

Description copied from interface: RegionServerServices

Returns the WAL for a particular region. Pass null for getting the default (common) WAL

Specified by:

getWAL in interface RegionServerServices

Throws:

IOException

getExecutorService

public ExecutorService getExecutorService()

Description copied from interface: RegionServerServices

Returns hbase executor service

Specified by:

getExecutorService in interface RegionServerServices

getChoreService

public ChoreService getChoreService()

Description copied from interface: Server

Returns The ChoreService instance for this server

Specified by:

getChoreService in interface Server

updateRegionFavoredNodesMapping

public void updateRegionFavoredNodesMapping(String encodedRegionName,
 List<org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ServerName> favoredNodes)

Description copied from interface: FavoredNodesForRegion

Used to update the favored nodes mapping when required.

Specified by:

updateRegionFavoredNodesMapping in interface FavoredNodesForRegion

getFavoredNodesForRegion

public InetSocketAddress[] getFavoredNodesForRegion(String encodedRegionName)

Description copied from interface: FavoredNodesForRegion

Get the favored nodes mapping for this region. Used when the HDFS create API is invoked to pass in favored nodes hints for new region files.

Specified by:

getFavoredNodesForRegion in interface FavoredNodesForRegion

Returns:

array containing the favored nodes' InetSocketAddresses

getNonceManager

public ServerNonceManager getNonceManager()

Description copied from interface: RegionServerServices

Only required for "old" log replay; if it's removed, remove this.

Specified by:

getNonceManager in interface RegionServerServices

Returns:

The RegionServer's NonceManager

reportRegionStateTransition

public boolean reportRegionStateTransition(RegionServerServices.RegionStateTransitionContext context)

Description copied from interface: RegionServerServices

Notify master that a handler requests to change a region state

Specified by:

reportRegionStateTransition in interface RegionServerServices

registerService

public boolean registerService(org.apache.hbase.thirdparty.com.google.protobuf.Service service)

Description copied from interface: RegionServerServices

Registers a new protocol buffer Service subclass as a coprocessor endpoint to be available for handling

Specified by:

registerService in interface RegionServerServices

Parameters:

service - the Service subclass instance to expose as a coprocessor endpoint

Returns:

true if the registration was successful, false

getHeapMemoryManager

public HeapMemoryManager getHeapMemoryManager()

Description copied from interface: RegionServerServices

Returns heap memory manager instance

Specified by:

getHeapMemoryManager in interface RegionServerServices

getCompactionPressure

public double getCompactionPressure()

Specified by:

getCompactionPressure in interface RegionServerServices

Returns:

the max compaction pressure of all stores on this regionserver. The value should be greater than or equal to 0.0, and any value greater than 1.0 means we enter the emergency state that some stores have too many store files.

See Also:

• Store.getCompactionPressure()

getFlushThroughputController

public ThroughputController getFlushThroughputController()

Description copied from interface: RegionServerServices

Returns the controller to avoid flush too fast

Specified by:

getFlushThroughputController in interface RegionServerServices

getFlushPressure

public double getFlushPressure()

Specified by:

getFlushPressure in interface RegionServerServices

Returns:

the flush pressure of all stores on this regionserver. The value should be greater than or equal to 0.0, and any value greater than 1.0 means we enter the emergency state that global memstore size already exceeds lower limit.

getMetrics

public MetricsRegionServer getMetrics()

Description copied from interface: RegionServerServices

Returns the metrics tracker for the region server

Specified by:

getMetrics in interface RegionServerServices

regionLock

public EntityLock regionLock(List<RegionInfo> regionInfos,
 String description,
 Abortable abort)
                      throws IOException

Description copied from interface: RegionServerServices

Master based locks on namespaces/tables/regions.

Specified by:

regionLock in interface RegionServerServices

Throws:

IOException

getSecureBulkLoadManager

public SecureBulkLoadManager getSecureBulkLoadManager()

Description copied from interface: RegionServerServices

Returns RegionServer's instance of SecureBulkLoadManager

Specified by:

getSecureBulkLoadManager in interface RegionServerServices

unassign

public void unassign(byte[] regionName)
              throws IOException

Description copied from interface: RegionServerServices

Unassign the given region from the current regionserver and assign it randomly. Could still be assigned to us. This is used to solve some tough problems for which you need to reset the state of a region. For example, if you hit FileNotFound exception and want to refresh the store file list.

See HBASE-17712 for more details.

Specified by:

unassign in interface RegionServerServices

Throws:

IOException

getRegionServerSpaceQuotaManager

public RegionServerSpaceQuotaManager getRegionServerSpaceQuotaManager()

Description copied from interface: RegionServerServices

Returns RegionServer's instance of RegionServerSpaceQuotaManager

Specified by:

getRegionServerSpaceQuotaManager in interface RegionServerServices

createConnection

public Connection createConnection(org.apache.hadoop.conf.Configuration conf)
                            throws IOException

Specified by:

createConnection in interface Server

Throws:

IOException

reportRegionSizesForQuotas

public boolean reportRegionSizesForQuotas(RegionSizeStore sizeStore)

Description copied from interface: RegionServerServices

Reports the provided Region sizes hosted by this RegionServer to the active Master.

Specified by:

reportRegionSizesForQuotas in interface RegionServerServices

Parameters:

sizeStore - The sizes for Regions locally hosted.

Returns:

false if reporting should be temporarily paused, true otherwise.

reportFileArchivalForQuotas

public boolean reportFileArchivalForQuotas(TableName tableName,
 Collection<Map.Entry<String,Long>> archivedFiles)

Description copied from interface: RegionServerServices

Reports a collection of files, and their sizes, that belonged to the given table were just moved to the archive directory.

Specified by:

reportFileArchivalForQuotas in interface RegionServerServices

Parameters:

tableName - The name of the table that files previously belonged to

archivedFiles - Files and their sizes that were moved to archive

Returns:

true if the files were successfully reported, false otherwise.

isClusterUp

public boolean isClusterUp()

Description copied from interface: RegionServerServices

Returns True if cluster is up; false if cluster is not up (we are shutting down).

Specified by:

isClusterUp in interface RegionServerServices

getReplicationSourceService

public ReplicationSourceService getReplicationSourceService()

Description copied from interface: RegionServerServices

Returns Return the object that implements the replication source executorService.

Specified by:

getReplicationSourceService in interface RegionServerServices

getTableDescriptors

public TableDescriptors getTableDescriptors()

Description copied from interface: RegionServerServices

Returns Return table descriptors implementation.

Specified by:

getTableDescriptors in interface RegionServerServices

getBlockCache

public Optional<BlockCache> getBlockCache()

Description copied from interface: RegionServerServices

Returns The block cache instance.

Specified by:

getBlockCache in interface RegionServerServices

getMobFileCache

public Optional<MobFileCache> getMobFileCache()

Description copied from interface: RegionServerServices

Returns The cache for mob files.

Specified by:

getMobFileCache in interface RegionServerServices

getAccessChecker

public AccessChecker getAccessChecker()

Description copied from interface: RegionServerServices

Returns the AccessChecker

Specified by:

getAccessChecker in interface RegionServerServices

getZKPermissionWatcher

public ZKPermissionWatcher getZKPermissionWatcher()

Description copied from interface: RegionServerServices

Returns ZKPermissionWatcher

Specified by:

getZKPermissionWatcher in interface RegionServerServices

getAsyncClusterConnection

public AsyncClusterConnection getAsyncClusterConnection()

Description copied from interface: Server

Returns a reference to the servers' async cluster connection.

Important note: this method returns a reference to Connection which is managed by Server itself, so callers must NOT attempt to close connection obtained.

Specified by:

getAsyncClusterConnection in interface Server

getRegionReplicationBufferManager

public RegionReplicationBufferManager getRegionReplicationBufferManager()

Specified by:

getRegionReplicationBufferManager in interface RegionServerServices