co.cask.cdap.data2.util.hbase

Class MockRegionServerServices

java.lang.Object

co.cask.cdap.data2.util.hbase.MockRegionServerServices

All Implemented Interfaces:

org.apache.hadoop.hbase.ipc.PriorityFunction, org.apache.hadoop.hbase.regionserver.RegionServerServices

public class MockRegionServerServices
extends Object
implements org.apache.hadoop.hbase.regionserver.RegionServerServices

Constructor Summary

Constructors

Constructor and Description
MockRegionServerServices(Configuration hConf, org.apache.hadoop.hbase.zookeeper.ZooKeeperWatcher zookeeper)

Method Summary

Methods

Modifier and Type	Method and Description
void	abort(String why, Throwable e)
void	addToOnlineRegions(org.apache.hadoop.hbase.regionserver.HRegion r)
org.apache.hadoop.hbase.catalog.CatalogTracker	getCatalogTracker()
org.apache.hadoop.hbase.regionserver.CompactionRequestor	getCompactionRequester()
Configuration	getConfiguration()
org.apache.hadoop.hbase.executor.ExecutorService	getExecutorService()
InetSocketAddress[]	getFavoredNodesForRegion(String encodedRegionName)
FileSystem	getFileSystem()
org.apache.hadoop.hbase.regionserver.FlushRequester	getFlushRequester()
org.apache.hadoop.hbase.regionserver.HRegion	getFromOnlineRegions(String encodedRegionName)
org.apache.hadoop.hbase.regionserver.Leases	getLeases()
org.apache.hadoop.hbase.regionserver.ServerNonceManager	getNonceManager()
List<org.apache.hadoop.hbase.regionserver.HRegion>	getOnlineRegions(org.apache.hadoop.hbase.TableName tableName)
int	getPriority(org.apache.hadoop.hbase.protobuf.generated.RPCProtos.RequestHeader requestHeader, com.google.protobuf.Message message)
Map<String,org.apache.hadoop.hbase.regionserver.HRegion>	getRecoveringRegions()
org.apache.hadoop.hbase.regionserver.RegionServerAccounting	getRegionServerAccounting()
ConcurrentMap<byte[],Boolean>	getRegionsInTransitionInRS()
org.apache.hadoop.hbase.ipc.RpcServerInterface	getRpcServer()
org.apache.hadoop.hbase.ServerName	getServerName()
org.apache.hadoop.hbase.master.TableLockManager	getTableLockManager()
org.apache.hadoop.hbase.regionserver.wal.HLog	getWAL(org.apache.hadoop.hbase.HRegionInfo regionInfo)
org.apache.hadoop.hbase.zookeeper.ZooKeeperWatcher	getZooKeeper()
boolean	isAborted()
boolean	isStopped()
boolean	isStopping()
void	postOpenDeployTasks(org.apache.hadoop.hbase.regionserver.HRegion r, org.apache.hadoop.hbase.catalog.CatalogTracker ct)
boolean	removeFromOnlineRegions(org.apache.hadoop.hbase.regionserver.HRegion r, org.apache.hadoop.hbase.ServerName destination)
boolean	reportRegionTransition(org.apache.hadoop.hbase.protobuf.generated.RegionServerStatusProtos.RegionTransition.TransitionCode transitionCode, org.apache.hadoop.hbase.HRegionInfo... hRegionInfos)
boolean	reportRegionTransition(org.apache.hadoop.hbase.protobuf.generated.RegionServerStatusProtos.RegionTransition.TransitionCode transitionCode, long l, org.apache.hadoop.hbase.HRegionInfo... hRegionInfos)
void	stop(String why)
void	updateRegionFavoredNodesMapping(String encodedRegionName, List<org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.ServerName> serverNames)

Methods inherited from class java.lang.Object

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

Constructor Detail

MockRegionServerServices

public MockRegionServerServices(Configuration hConf,
                        org.apache.hadoop.hbase.zookeeper.ZooKeeperWatcher zookeeper)

Method Detail

isStopping

public boolean isStopping()

Specified by:

isStopping in interface org.apache.hadoop.hbase.regionserver.RegionServerServices

getWAL

public org.apache.hadoop.hbase.regionserver.wal.HLog getWAL(org.apache.hadoop.hbase.HRegionInfo regionInfo)
                                                     throws IOException

Specified by:

getWAL in interface org.apache.hadoop.hbase.regionserver.RegionServerServices

Throws:

IOException

getCompactionRequester

public org.apache.hadoop.hbase.regionserver.CompactionRequestor getCompactionRequester()

Specified by:

getCompactionRequester in interface org.apache.hadoop.hbase.regionserver.RegionServerServices

getFlushRequester

public org.apache.hadoop.hbase.regionserver.FlushRequester getFlushRequester()

Specified by:

getFlushRequester in interface org.apache.hadoop.hbase.regionserver.RegionServerServices

getRegionServerAccounting

public org.apache.hadoop.hbase.regionserver.RegionServerAccounting getRegionServerAccounting()

Specified by:

getRegionServerAccounting in interface org.apache.hadoop.hbase.regionserver.RegionServerServices

getTableLockManager

public org.apache.hadoop.hbase.master.TableLockManager getTableLockManager()

Specified by:

getTableLockManager in interface org.apache.hadoop.hbase.regionserver.RegionServerServices

postOpenDeployTasks

public void postOpenDeployTasks(org.apache.hadoop.hbase.regionserver.HRegion r,
                       org.apache.hadoop.hbase.catalog.CatalogTracker ct)
                         throws org.apache.zookeeper.KeeperException,
                                IOException

Specified by:

postOpenDeployTasks in interface org.apache.hadoop.hbase.regionserver.RegionServerServices

Throws:

org.apache.zookeeper.KeeperException

IOException

getRpcServer

public org.apache.hadoop.hbase.ipc.RpcServerInterface getRpcServer()

Specified by:

getRpcServer in interface org.apache.hadoop.hbase.regionserver.RegionServerServices

getRegionsInTransitionInRS

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

Specified by:

getRegionsInTransitionInRS in interface org.apache.hadoop.hbase.regionserver.RegionServerServices

getFileSystem

public FileSystem getFileSystem()

Specified by:

getFileSystem in interface org.apache.hadoop.hbase.regionserver.RegionServerServices

getLeases

public org.apache.hadoop.hbase.regionserver.Leases getLeases()

Specified by:

getLeases in interface org.apache.hadoop.hbase.regionserver.RegionServerServices

getExecutorService

public org.apache.hadoop.hbase.executor.ExecutorService getExecutorService()

Specified by:

getExecutorService in interface org.apache.hadoop.hbase.regionserver.RegionServerServices

getCatalogTracker

public org.apache.hadoop.hbase.catalog.CatalogTracker getCatalogTracker()

Specified by:

getCatalogTracker in interface org.apache.hadoop.hbase.regionserver.RegionServerServices

getRecoveringRegions

public Map<String,org.apache.hadoop.hbase.regionserver.HRegion> getRecoveringRegions()

Specified by:

getRecoveringRegions in interface org.apache.hadoop.hbase.regionserver.RegionServerServices

updateRegionFavoredNodesMapping

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

getOnlineRegions

public List<org.apache.hadoop.hbase.regionserver.HRegion> getOnlineRegions(org.apache.hadoop.hbase.TableName tableName)
                                                                    throws IOException

Throws:

IOException

getFavoredNodesForRegion

public InetSocketAddress[] getFavoredNodesForRegion(String encodedRegionName)

addToOnlineRegions

public void addToOnlineRegions(org.apache.hadoop.hbase.regionserver.HRegion r)

removeFromOnlineRegions

public boolean removeFromOnlineRegions(org.apache.hadoop.hbase.regionserver.HRegion r,
                              org.apache.hadoop.hbase.ServerName destination)

getFromOnlineRegions

public org.apache.hadoop.hbase.regionserver.HRegion getFromOnlineRegions(String encodedRegionName)

getConfiguration

public Configuration getConfiguration()

getZooKeeper

public org.apache.hadoop.hbase.zookeeper.ZooKeeperWatcher getZooKeeper()

getServerName

public org.apache.hadoop.hbase.ServerName getServerName()

abort

public void abort(String why,
         Throwable e)

isAborted

public boolean isAborted()

stop

public void stop(String why)

isStopped

public boolean isStopped()

reportRegionTransition

public boolean reportRegionTransition(org.apache.hadoop.hbase.protobuf.generated.RegionServerStatusProtos.RegionTransition.TransitionCode transitionCode,
                             long l,
                             org.apache.hadoop.hbase.HRegionInfo... hRegionInfos)

Specified by:

reportRegionTransition in interface org.apache.hadoop.hbase.regionserver.RegionServerServices

reportRegionTransition

public boolean reportRegionTransition(org.apache.hadoop.hbase.protobuf.generated.RegionServerStatusProtos.RegionTransition.TransitionCode transitionCode,
                             org.apache.hadoop.hbase.HRegionInfo... hRegionInfos)

Specified by:

reportRegionTransition in interface org.apache.hadoop.hbase.regionserver.RegionServerServices

getNonceManager

public org.apache.hadoop.hbase.regionserver.ServerNonceManager getNonceManager()

Specified by:

getNonceManager in interface org.apache.hadoop.hbase.regionserver.RegionServerServices

getPriority

public int getPriority(org.apache.hadoop.hbase.protobuf.generated.RPCProtos.RequestHeader requestHeader,
              com.google.protobuf.Message message)

Specified by:

getPriority in interface org.apache.hadoop.hbase.ipc.PriorityFunction