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, org.apache.hadoop.hbase.Abortable, org.apache.hadoop.hbase.conf.ConfigurationObserver, org.apache.hadoop.hbase.regionserver.FavoredNodesForRegion, org.apache.hadoop.hbase.regionserver.LastSequenceId, org.apache.hadoop.hbase.regionserver.MutableOnlineRegions, org.apache.hadoop.hbase.regionserver.OnlineRegions, org.apache.hadoop.hbase.regionserver.RegionServerServices, org.apache.hadoop.hbase.Server, org.apache.hadoop.hbase.Stoppable

Direct Known Subclasses:

TestClientOperationTimeout.DelayedRegionServer, TestClientScannerRPCTimeout.RegionServerWithScanTimeout, TestLocalHBaseCluster.MyHRegionServer, TestMetaShutdownHandler.MyRegionServer, TestMovedRegionsCleaner.TestMockRegionServer, TestRegionServerReportForDuty.MyRegionServer, TestRSKilledWhenInitializing.RegisterAndDieRegionServer

Enclosing class:

MiniHBaseCluster

public static class MiniHBaseCluster.MiniHBaseClusterRegionServer
extends org.apache.hadoop.hbase.regionserver.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

org.apache.hadoop.hbase.regionserver.HRegionServer.MovedRegionsCleaner

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

org.apache.hadoop.hbase.regionserver.RegionServerServices.PostOpenDeployContext, org.apache.hadoop.hbase.regionserver.RegionServerServices.RegionStateTransitionContext

Field Summary

Fields

Modifier and Type	Field and Description
(package private) static Set<org.apache.hadoop.hbase.ServerName>	killedServers List of RegionServers killed so far.
private Thread	shutdownThread
private org.apache.hadoop.hbase.security.User	user

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

ABORT_TIMEOUT, ABORT_TIMEOUT_TASK, cacheConfig, cacheFlusher, clusterConnection, clusterId, clusterStatusTracker, compactSplitThread, conf, configurationManager, csm, executorService, fs, fsOk, fsUtilizationChore, hMemManager, infoServer, leases, lock, MASTER_HOSTNAME_KEY, metaTableLocator, movedRegions, msgInterval, numRegionsToReport, onlineRegions, regionFavoredNodesMap, REGIONSERVER, regionsInTransitionInRS, replicationSinkHandler, replicationSourceHandler, rpcServices, secureBulkLoadManager, serverName, sleeper, startcode, tableDescriptors, TEST_SKIP_REPORTING_TRANSITION, threadWakeFrequency, useThisHostnameInstead, walFactory, walFs, walRoller, zooKeeper

Constructor Summary

Constructors

Constructor and Description
MiniHBaseClusterRegionServer(org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
void	abort(String reason, Throwable cause)
private void	abortRegionServer(String reason, Throwable cause)
protected void	handleReportForDutyResponse(org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionServerStartupResponse c)
protected void	kill()
void	run()
private void	runRegionServer()

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

abort, addRegion, addToMovedRegions, canCreateBaseZNode, canUpdateTableDescriptor, checkFileSystem, cleanMovedRegions, clearRegionBlockCache, closeAllRegions, closeAndOfflineRegionForSplitOrMerge, closeRegion, configureInfoServer, constructRegionServer, convertThrowableToIOE, createClusterConnection, createConnection, createRegionLoad, createRegionServerStatusStub, createRegionServerStatusStub, createRpcServices, execRegionServerService, getCacheConfig, getChoreService, getClusterConnection, getClusterId, getCompactionPressure, getCompactionRequestor, getCompactSplitThread, getConfiguration, getConfigurationManager, getConnection, getCoordinatedStateManager, getDumpServlet, getEventLoopGroupConfig, getExecutorService, getFavoredNodesForRegion, getFileSystem, getFlushPressure, getFlushRequester, getFlushThroughputController, getFsTableDescriptors, getHeapMemoryManager, getInfoServer, getLastSequenceId, getLeases, getMasterAddressTracker, getMetaTableLocator, getMetaTableObserver, getMetrics, getMostLoadedRegions, getNonceManager, getNumberOfOnlineRegions, getOnlineRegion, getOnlineRegionsLocalContext, getOnlineTables, getProcessName, getRegion, getRegion, getRegionBlockLocations, getRegionByEncodedName, getRegionByEncodedName, getRegions, getRegions, getRegionServerAccounting, getRegionServerCoprocessorHost, getRegionServerCoprocessors, getRegionServerMetrics, getRegionServerRpcQuotaManager, getRegionServerSpaceQuotaManager, getRegionsInTransitionInRS, getReplicationSourceService, getRootDir, getRpcServer, getRSRpcServices, getSecureBulkLoadManager, getServerName, getStartcode, getTableDescriptors, getThreadWakeFrequency, getUseThisHostnameInstead, getWAL, getWALFileSystem, getWalRoller, getWALRootDir, getWALs, getZooKeeper, initializeMemStoreChunkCreator, isAborted, isClusterUp, isOnline, isStopped, isStopping, login, main, movedRegionCleanerPeriod, onConfigurationChange, postOpenDeployTasks, regionLock, registerService, removeRegion, reportRegionSizesForQuotas, reportRegionStateTransition, sendShutdownInterrupt, setupClusterConnection, stop, stop, stopServiceThreads, toString, tryRegionServerReport, unassign, updateConfiguration, updateRegionFavoredNodesMapping, waitForMasterActive, waitForServerOnline, walRollRequestFinished

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

shutdownThread

private Thread shutdownThread

user

private org.apache.hadoop.hbase.security.User user

killedServers

static Set<org.apache.hadoop.hbase.ServerName> killedServers

List of RegionServers killed so far. ServerName also comprises startCode of a server, so any restarted instances of the same server will have different ServerName and will not coincide with past dead ones. So there's no need to cleanup this list.

Constructor Detail

MiniHBaseClusterRegionServer

public MiniHBaseClusterRegionServer(org.apache.hadoop.conf.Configuration conf)
                             throws IOException,
                                    InterruptedException

Throws:

IOException

InterruptedException

Method Detail

handleReportForDutyResponse

protected void handleReportForDutyResponse(org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionServerStartupResponse c)
                                    throws IOException

Overrides:

handleReportForDutyResponse in class org.apache.hadoop.hbase.regionserver.HRegionServer

Throws:

IOException

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class org.apache.hadoop.hbase.regionserver.HRegionServer

runRegionServer

private void runRegionServer()

kill

protected void kill()

Overrides:

kill in class org.apache.hadoop.hbase.regionserver.HRegionServer

abort

public void abort(String reason,
                  Throwable cause)

Specified by:

abort in interface org.apache.hadoop.hbase.Abortable

Overrides:

abort in class org.apache.hadoop.hbase.regionserver.HRegionServer

abortRegionServer

private void abortRegionServer(String reason,
                               Throwable cause)