Package org.apache.hadoop.hbase

Class MiniHBaseCluster.MiniHBaseClusterRegionServer

java.lang.Object

java.lang.Thread

org.apache.hadoop.hbase.HBaseServerBase<RSRpcServices>

org.apache.hadoop.hbase.regionserver.HRegionServer

org.apache.hadoop.hbase.MiniHBaseCluster.MiniHBaseClusterRegionServer

All Implemented Interfaces:

Runnable, Abortable, ConnectionRegistryEndpoint, ConfigurationObserver, FavoredNodesForRegion, LastSequenceId, MutableOnlineRegions, OnlineRegions, RegionServerServices, Server, Stoppable

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 java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

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

RegionServerServices.PostOpenDeployContext, RegionServerServices.RegionStateTransitionContext

Field Summary

Fields

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

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

REGIONSERVER, TEST_SKIP_REPORTING_TRANSITION

Fields inherited from class org.apache.hadoop.hbase.HBaseServerBase

abortRequested, asyncClusterConnection, choreService, clusterStatusTracker, conf, configurationManager, csm, dataFs, dataRootDir, eventLoopGroupConfig, executorService, infoServer, metaRegionLocationCache, msgInterval, namedQueueRecorder, rpcServices, serverName, sleeper, startcode, stopped, tableDescriptors, userProvider, useThisHostnameInstead, walFs, walRootDir, zooKeeper

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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.
private void	abortRegionServer(String reason, Throwable cause)
protected void	handleReportForDutyResponse(org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionServerStartupResponse c)	Run init.
protected void	kill()
void	run()	The HRegionServer sticks in this loop until closed.
private void	runRegionServer()

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

addRegion, cacheTableDescriptor, canCreateBaseZNode, canUpdateTableDescriptor, closeRegion, clusterMode, configureInfoServer, createNamedQueueRecord, createRegionLoad, createRegionServerStatusStub, createRpcServices, dumpRowLocks, finishRegionProcedure, getActiveMaster, getBackupMasters, getBlockCache, getBootstrapNodes, getBrokenStoreFileCleaner, getClusterId, getCompactedHFilesDischarger, getCompactionPressure, getCompactionRequestor, getCompactSplitThread, getCoprocessorHost, getDumpServlet, getFavoredNodesForRegion, getFlushPressure, getFlushRequester, getFlushThroughputController, getHeapMemoryManager, getLastSequenceId, getLeaseManager, getMasterAddressTracker, getMemStoreFlusher, getMetaLocations, getMetrics, getMobFileCache, getMovedRegion, getNonceManager, getNumberOfOnlineRegions, getOnlineRegion, getOnlineRegions, getOnlineRegionsLocalContext, getOnlineTables, getProcessName, getRegion, getRegion, getRegionByEncodedName, getRegionReplicationBufferManager, getRegions, getRegions, getRegionServerAccounting, getRegionServerCoprocessorHost, getRegionServerCoprocessors, getRegionServerRpcQuotaManager, getRegionServerSpaceQuotaManager, getRegionsInTransitionInRS, getReplicationSinkService, getReplicationSourceService, getRetryPauseTime, getRSMobFileCleanerChore, getRSRpcServices, getSecureBulkLoadManager, getUseThisHostnameInstead, getWAL, getWalFactory, getWalGroupsReplicationStatus, getWalRoller, getWALs, isClusterUp, isOnline, isStopping, login, main, movedRegionCacheExpiredTime, onConfigurationChange, postOpenDeployTasks, regionLock, registerService, remoteProcedureComplete, removeRegion, reportFileArchivalForQuotas, reportRegionSizesForQuotas, reportRegionStateTransition, stop, stop, stopChores, stopServiceThreads, tryRegionServerReport, unassign, updateRegionFavoredNodesMapping, waitForServerOnline, walRollRequestFinished

Methods inherited from class org.apache.hadoop.hbase.HBaseServerBase

closeClusterConnection, closeTableDescriptors, closeZooKeeper, createConnection, getAccessChecker, getAsyncClusterConnection, getChoreService, getConfiguration, getConfigurationManager, getCoordinatedStateManager, getDataRootDir, getEventLoopGroupConfig, getExecutorService, getFileSystem, getInfoServer, getMetaRegionLocationCache, getMsgInterval, getNamedQueueRecorder, getRpcServer, getRpcServices, getServerName, getStartcode, getTableDescriptors, getWALFileSystem, getWALRootDir, getZKPermissionWatcher, getZooKeeper, initializeFileSystem, initializeMemStoreChunkCreator, installShutdownHook, isAborted, isShutdownHookInstalled, isStopped, setAbortRequested, setupClusterConnection, shutdownChore, stopChoreService, stopExecutorService, stopInfoServer, toString, updateConfiguration

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, yield

Methods inherited from class java.lang.Object

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

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

abort, isAborted

Methods inherited from interface org.apache.hadoop.hbase.regionserver.RegionServerServices

getAccessChecker, getExecutorService, getRpcServer, getTableDescriptors, getZKPermissionWatcher

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

createConnection, getAsyncClusterConnection, getAsyncConnection, getChoreService, getConfiguration, getConnection, getCoordinatedStateManager, getFileSystem, getServerName, getZooKeeper

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

isStopped

Field Details

shutdownThread

private Thread shutdownThread

user

private User user

killedServers

static Set<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 Details

MiniHBaseClusterRegionServer

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

Throws:

IOException

InterruptedException

Method Details

handleReportForDutyResponse

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

Description copied from class: HRegionServer

Run init. Sets up wal and starts up all server threads.

Overrides:

handleReportForDutyResponse in class HRegionServer

Parameters:

c - Extra configuration.

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

runRegionServer

private void runRegionServer()

kill

protected 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. the reason we are aborting the exception that caused the abort, or null

Specified by:

abort in interface Abortable

Overrides:

abort in class HRegionServer

Parameters:

reason - Why we're aborting.

cause - Throwable that caused abort. Can be null.

abortRegionServer

private void abortRegionServer(String reason,
 Throwable cause)