public static class MiniHBaseCluster.MiniHBaseClusterRegionServer extends HRegionServer
Thread.State, Thread.UncaughtExceptionHandler
RegionServerServices.PostOpenDeployContext, RegionServerServices.RegionStateTransitionContext
Modifier and Type | Field and Description |
---|---|
(package private) static Set<ServerName> |
killedServers
List of RegionServers killed so far.
|
private Thread |
shutdownThread |
private User |
user |
REGIONSERVER, TEST_SKIP_REPORTING_TRANSITION
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
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
MiniHBaseClusterRegionServer(org.apache.hadoop.conf.Configuration conf) |
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.
|
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() |
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
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
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, yield
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getAccessChecker, getExecutorService, getRpcServer, getTableDescriptors, getZKPermissionWatcher
createConnection, getAsyncClusterConnection, getAsyncConnection, getChoreService, getConfiguration, getConnection, getCoordinatedStateManager, getFileSystem, getServerName, getZooKeeper
private Thread shutdownThread
static Set<ServerName> killedServers
public MiniHBaseClusterRegionServer(org.apache.hadoop.conf.Configuration conf) throws IOException, InterruptedException
IOException
InterruptedException
protected void handleReportForDutyResponse(org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionServerStartupResponse c) throws IOException
HRegionServer
handleReportForDutyResponse
in class HRegionServer
c
- Extra configuration.IOException
public void run()
HRegionServer
run
in interface Runnable
run
in class HRegionServer
private void runRegionServer()
protected void kill()
kill
in class HRegionServer
public void abort(String reason, Throwable cause)
HRegionServer
abort
in interface Abortable
abort
in class HRegionServer
reason
- Why we're aborting.cause
- Throwable that caused abort. Can be null.private void abortRegionServer(String reason, Throwable cause)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.