org.apache.hadoop.hbase

Class MiniHBaseCluster.MiniHBaseClusterRegionServer

java.lang.Object

org.apache.hadoop.hbase.util.HasThread

org.apache.hadoop.hbase.regionserver.HRegionServer

org.apache.hadoop.hbase.MiniHBaseCluster.MiniHBaseClusterRegionServer

All Implemented Interfaces:

Runnable, Abortable, FavoredNodesForRegion, LastSequenceId, OnlineRegions, RegionServerServices, Server, Stoppable

Direct Known Subclasses:

TestAssignmentManagerOnCluster.MyRegionServer, TestMetaShutdownHandler.MyRegionServer, TestRegionServerReportForDuty.MyRegionServer, TestRSKilledWhenInitializing.MockedRegionServer

Enclosing class:

MiniHBaseCluster

public static class MiniHBaseCluster.MiniHBaseClusterRegionServer
extends HRegionServer

Subclass so can get at protected methods (none at moment). Also, creates a FileSystem instance per instantiation. Adds a shutdown own FileSystem on the way out. Shuts down own Filesystem only, not All filesystems as the FileSystem system exit hook does.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.regionserver.HRegionServer

HRegionServer.MovedRegionsCleaner

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
static boolean	TEST_SKIP_CLOSE

Fields inherited from class org.apache.hadoop.hbase.regionserver.HRegionServer

cacheConfig, cacheFlusher, CLOSE, clusterConnection, clusterStatusTracker, compactSplitThread, conf, configurationManager, csm, fs, fsOk, fsUtilizationChore, hMemManager, infoServer, initLatch, leases, lock, LOG, metaTableLocator, movedRegions, msgInterval, numRegionsToReport, onlineRegions, OPEN, recoveringRegions, regionFavoredNodesMap, REGIONSERVER, regionsInTransitionInRS, replicationSinkHandler, replicationSourceHandler, rpcServices, serverName, service, sleeper, startcode, tableDescriptors, tableLockManager, threadWakeFrequency, walFactory, walFs, zooKeeper

Constructor Summary

Constructors

Constructor and Description
MiniHBaseClusterRegionServer(Configuration conf, CoordinatedStateManager cp)

Method Summary

Modifier and Type	Method and Description
void	abort(String reason, Throwable cause) Cause the server to exit without closing the regions it is serving, the log it is using and without notifying the master.
protected void	handleReportForDutyResponse(RegionServerStatusProtos.RegionServerStartupResponse c)
void	kill()
void	run() The HRegionServer sticks in this loop until closed.

Methods inherited from class org.apache.hadoop.hbase.regionserver.HRegionServer

abort, addToMovedRegions, addToOnlineRegions, canCreateBaseZNode, canUpdateTableDescriptor, checkFileSystem, cleanMovedRegions, closeAllRegions, closeRegion, configureInfoServer, constructRegionServer, convertThrowableToIOE, createClusterConnection, createRegionLoad, createRegionServerStatusStub, createRpcServices, doMetrics, ensureMetaWALRoller, execRegionServerService, getCacheConfig, getChoreService, getClusterId, getCompactionPressure, getCompactionRequester, getCompactSplitThread, getConfiguration, getConfigurationManager, getConnection, getCoordinatedStateManager, getDumpServlet, getExecutorService, getFavoredNodesForRegion, getFileSystem, getFlushRequester, getFromOnlineRegions, getHeapMemoryManager, getInfoServer, getLastSequenceId, getLeases, getMasterAddressTracker, getMetaTableLocator, getMetrics, getMostLoadedRegions, getNonceManager, getNumberOfOnlineRegions, getOnlineRegion, getOnlineRegions, getOnlineRegions, getOnlineRegionsLocalContext, getOnlineTables, getProcessName, getRecoveringRegions, getRegion, getRegionBlockLocations, getRegionByEncodedName, getRegionByEncodedName, getRegionServerAccounting, getRegionServerCoprocessorHost, getRegionServerCoprocessors, getRegionServerMetrics, getRegionServerRpcQuotaManager, getRegionServerSpaceQuotaManager, getRegionsInTransitionInRS, getRootDir, getRpcServer, getRSRpcServices, getServerName, getStartcode, getTableDescriptors, getTableLockManager, getThreadWakeFrequency, getWAL, getWALFileSystem, getWALRootDir, getZooKeeper, isAborted, isOnline, isStopped, isStopping, login, main, movedRegionCleanerPeriod, postOpenDeployTasks, postOpenDeployTasks, registerService, removeFromOnlineRegions, reportRegionSizesForQuotas, reportRegionStateTransition, reportRegionStateTransition, reportRegionStateTransition, sendShutdownInterrupt, setInitLatch, setupClusterConnection, shouldUseThisHostnameInstead, stop, stopServiceThreads, toString, tryRegionServerReport, updateConfiguration, updateRegionFavoredNodesMapping, waitForMasterActive, waitForServerOnline

Methods inherited from class org.apache.hadoop.hbase.util.HasThread

getName, getThread, interrupt, isAlive, isInterrupted, join, join, join, setDaemon, setName, setPriority, setUncaughtExceptionHandler, start

Methods inherited from class java.lang.Object

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

Field Detail

TEST_SKIP_CLOSE

public static boolean TEST_SKIP_CLOSE

Constructor Detail

MiniHBaseClusterRegionServer

public MiniHBaseClusterRegionServer(Configuration conf,
                                    CoordinatedStateManager cp)
                             throws IOException,
                                    InterruptedException

Throws:

IOException

InterruptedException

Method Detail

handleReportForDutyResponse

protected void handleReportForDutyResponse(RegionServerStatusProtos.RegionServerStartupResponse c)
                                    throws IOException

Overrides:

handleReportForDutyResponse in class HRegionServer

Throws:

IOException

run

public void run()

Description copied from class: HRegionServer

The HRegionServer sticks in this loop until closed.

Specified by:

run in interface Runnable

Overrides:

run in class HRegionServer

kill

public void kill()

Overrides:

kill in class HRegionServer

abort

public void abort(String reason,
                  Throwable cause)

Description copied from class: HRegionServer

Cause the server to exit without closing the regions it is serving, the log it is using and without notifying the master. Used unit testing and on catastrophic events such as HDFS is yanked out from under hbase or we OOME.

Specified by:

abort in interface Abortable

Overrides:

abort in class HRegionServer

Parameters:

reason - the reason we are aborting

cause - the exception that caused the abort, or null