org.apache.hadoop.hbase

Class MockRegionServerServices

java.lang.Object

org.apache.hadoop.hbase.MockRegionServerServices

All Implemented Interfaces:

Abortable, FavoredNodesForRegion, OnlineRegions, RegionServerServices, Server, Stoppable

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 and Description
protected static Log	LOG

Constructor Summary

Constructors

Constructor and Description
MockRegionServerServices(Configuration conf)

Method Summary

Modifier and Type	Method and Description
void	abort(String why, Throwable e) Abort the server or client.
void	addToOnlineRegions(Region r) Add to online regions.
ChoreService	getChoreService()
double	getCompactionPressure()
CompactionRequestor	getCompactionRequester()
Configuration	getConfiguration() Gets the configuration object for this server.
ClusterConnection	getConnection() Returns a reference to the servers' cluster connection.
CoordinatedStateManager	getCoordinatedStateManager() Get CoordinatedStateManager instance for this server.
ExecutorService	getExecutorService()
InetSocketAddress[]	getFavoredNodesForRegion(String encodedRegionName) Get the favored nodes mapping for this region.
HFileSystem	getFileSystem()
FlushRequester	getFlushRequester()
Region	getFromOnlineRegions(String encodedRegionName) Return Region instance.
HeapMemoryManager	getHeapMemoryManager()
Leases	getLeases()
MetaTableLocator	getMetaTableLocator() Returns instance of MetaTableLocator running inside this server.
MetricsRegionServer	getMetrics()
ServerNonceManager	getNonceManager() Only required for "old" log replay; if it's removed, remove this.
List<Region>	getOnlineRegions(TableName tableName) Get all online regions of a table in this RS.
Set<TableName>	getOnlineTables()
Map<String,Region>	getRecoveringRegions()
RegionServerAccounting	getRegionServerAccounting()
RegionServerRpcQuotaManager	getRegionServerRpcQuotaManager()
RegionServerSpaceQuotaManager	getRegionServerSpaceQuotaManager()
ConcurrentSkipListMap<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
ServerName	getServerName()
TableLockManager	getTableLockManager()
WAL	getWAL(HRegionInfo regionInfo)
ZooKeeperWatcher	getZooKeeper() Gets the ZooKeeper instance for this server.
boolean	isAborted() Check if the server or client was aborted.
boolean	isStopped()
boolean	isStopping()
void	postOpenDeployTasks(Region r) Tasks to perform after region open to complete deploy of region on regionserver
void	postOpenDeployTasks(RegionServerServices.PostOpenDeployContext context) Tasks to perform after region open to complete deploy of region on regionserver
boolean	registerService(Service service) Registers a new protocol buffer Service subclass as a coprocessor endpoint to be available for handling
boolean	removeFromOnlineRegions(Region r, ServerName destination) This method removes Region corresponding to hri from the Map of onlineRegions.
boolean	reportRegionStateTransition(RegionServerServices.RegionStateTransitionContext context) Notify master that a handler requests to change a region state
boolean	reportRegionStateTransition(RegionServerStatusProtos.RegionStateTransition.TransitionCode code, HRegionInfo... hris) Notify master that a handler requests to change a region state
boolean	reportRegionStateTransition(RegionServerStatusProtos.RegionStateTransition.TransitionCode code, long openSeqNum, HRegionInfo... hris) Notify master that a handler requests to change a region state
void	setFileSystem(FileSystem hfs)
void	setRpcServer(RpcServerInterface rpc)
void	stop(String why) Stop this service.
void	updateRegionFavoredNodesMapping(String encodedRegionName, List<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

Field Detail

LOG

protected static final Log LOG

Constructor Detail

MockRegionServerServices

public MockRegionServerServices(Configuration conf)

Method Detail

removeFromOnlineRegions

public boolean removeFromOnlineRegions(Region r,
                                       ServerName destination)

Description copied from interface: OnlineRegions

This method removes Region corresponding to hri from the Map of onlineRegions.

Specified by:

removeFromOnlineRegions in interface OnlineRegions

Parameters:

r - Region to remove.

destination - Destination, if any, null otherwise.

Returns:

True if we removed a region from online list.

getFromOnlineRegions

public Region getFromOnlineRegions(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:

getFromOnlineRegions in interface OnlineRegions

Returns:

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

getOnlineRegions

public List<Region> getOnlineRegions(TableName tableName)
                              throws IOException

Description copied from interface: OnlineRegions

Get all online regions of a table in this RS.

Specified by:

getOnlineRegions in interface OnlineRegions

Returns:

List of Region

Throws:

IOException

getOnlineTables

public Set<TableName> getOnlineTables()

Specified by:

getOnlineTables in interface RegionServerServices

Returns:

all the online tables in this RS

addToOnlineRegions

public void addToOnlineRegions(Region r)

Description copied from interface: OnlineRegions

Add to online regions.

Specified by:

addToOnlineRegions in interface OnlineRegions

postOpenDeployTasks

public void postOpenDeployTasks(Region r)
                         throws KeeperException,
                                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:

r - Region to open.

Throws:

KeeperException

IOException

postOpenDeployTasks

public void postOpenDeployTasks(RegionServerServices.PostOpenDeployContext context)
                         throws KeeperException,
                                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:

KeeperException

IOException

isStopping

public boolean isStopping()

Specified by:

isStopping in interface RegionServerServices

Returns:

True if this regionserver is stopping.

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.

getCompactionRequester

public CompactionRequestor getCompactionRequester()

Specified by:

getCompactionRequester in interface RegionServerServices

Returns:

Implementation of CompactionRequestor or null.

getConnection

public ClusterConnection getConnection()

Description copied from interface: Server

Returns a reference to the servers' 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:

getConnection in interface Server

getMetaTableLocator

public MetaTableLocator getMetaTableLocator()

Description copied from interface: Server

Returns instance of MetaTableLocator running inside this server. This MetaServerLocator is started and stopped by server, clients shouldn't manage it's lifecycle.

Specified by:

getMetaTableLocator in interface Server

Returns:

instance of MetaTableLocator associated with this server.

getZooKeeper

public ZooKeeperWatcher 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()

Specified by:

getRegionServerAccounting in interface RegionServerServices

Returns:

the RegionServerAccounting for this Region Server

getTableLockManager

public TableLockManager getTableLockManager()

Specified by:

getTableLockManager in interface RegionServerServices

Returns:

RegionServer's instance of TableLockManager

getRegionServerRpcQuotaManager

public RegionServerRpcQuotaManager getRegionServerRpcQuotaManager()

Specified by:

getRegionServerRpcQuotaManager in interface RegionServerServices

Returns:

RegionServer's instance of RegionServerRpcQuotaManager

getServerName

public ServerName getServerName()

Specified by:

getServerName in interface Server

Returns:

The unique server name for this server.

getConfiguration

public 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.

Specified by:

stop in interface Stoppable

Parameters:

why - Why we're stopping.

isStopped

public boolean isStopped()

Specified by:

isStopped in interface Stoppable

Returns:

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

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()

Specified by:

getFileSystem in interface RegionServerServices

Returns:

Return the FileSystem object used by the regionserver

setFileSystem

public void setFileSystem(FileSystem hfs)

getLeases

public Leases getLeases()

Specified by:

getLeases in interface RegionServerServices

Returns:

The RegionServer's "Leases" service

getWAL

public WAL getWAL(HRegionInfo regionInfo)
           throws IOException

Specified by:

getWAL in interface RegionServerServices

Returns:

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

Throws:

IOException

getExecutorService

public ExecutorService getExecutorService()

Specified by:

getExecutorService in interface RegionServerServices

Returns:

hbase executor service

getChoreService

public ChoreService getChoreService()

Specified by:

getChoreService in interface Server

Returns:

The ChoreService instance for this server

updateRegionFavoredNodesMapping

public void updateRegionFavoredNodesMapping(String encodedRegionName,
                                            List<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

getRecoveringRegions

public Map<String,Region> getRecoveringRegions()

Specified by:

getRecoveringRegions in interface RegionServerServices

Returns:

set of recovering regions on the hosting region server

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(RegionServerStatusProtos.RegionStateTransition.TransitionCode code,
                                           long openSeqNum,
                                           HRegionInfo... hris)

Description copied from interface: RegionServerServices

Notify master that a handler requests to change a region state

Specified by:

reportRegionStateTransition in interface RegionServerServices

reportRegionStateTransition

public boolean reportRegionStateTransition(RegionServerStatusProtos.RegionStateTransition.TransitionCode code,
                                           HRegionInfo... hris)

Description copied from interface: RegionServerServices

Notify master that a handler requests to change a region state

Specified by:

reportRegionStateTransition in interface RegionServerServices

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(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()

Specified by:

getHeapMemoryManager in interface RegionServerServices

Returns:

heap memory manager instance

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()

getMetrics

public MetricsRegionServer getMetrics()

Specified by:

getMetrics in interface RegionServerServices

Returns:

the metrics tracker for the region server

getRegionServerSpaceQuotaManager

public RegionServerSpaceQuotaManager getRegionServerSpaceQuotaManager()

Specified by:

getRegionServerSpaceQuotaManager in interface RegionServerServices

Returns:

RegionServer's instance of RegionServerSpaceQuotaManager