public static class TestRegionServerReportForDuty.MyRegionServer extends MiniHBaseCluster.MiniHBaseClusterRegionServer
HRegionServer.MovedRegionsCleanerRegionServerServices.PostOpenDeployContext, RegionServerServices.RegionStateTransitionContextTEST_SKIP_CLOSEcacheConfig, cacheFlusher, CLOSE, clusterConnection, clusterStatusTracker, compactSplitThread, conf, configurationManager, csm, fs, fsOk, 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, zooKeeper| Constructor and Description |
|---|
MyRegionServer(Configuration conf,
CoordinatedStateManager cp) |
| Modifier and Type | Method and Description |
|---|---|
protected ServerName |
createRegionServerStatusStub()
Get the current master from ZooKeeper and open the RPC connection to it.
|
boolean |
getRpcStubCreatedFlag() |
abort, handleReportForDutyResponse, kill, runabort, addToMovedRegions, addToOnlineRegions, canCreateBaseZNode, canUpdateTableDescriptor, checkFileSystem, cleanMovedRegions, closeAllRegions, closeRegion, configureInfoServer, constructRegionServer, convertThrowableToIOE, createClusterConnection, createRegionLoad, 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, getOnlineRegionsLocalContext, getOnlineTables, getProcessName, getRecoveringRegions, getRegion, getRegionBlockLocations, getRegionByEncodedName, getRegionByEncodedName, getRegionServerAccounting, getRegionServerCoprocessorHost, getRegionServerCoprocessors, getRegionServerMetrics, getRegionServerQuotaManager, getRegionsInTransitionInRS, getRootDir, getRpcServer, getRSRpcServices, getServerName, getStartcode, getTableDescriptors, getTableLockManager, getThreadWakeFrequency, getWAL, getZooKeeper, isAborted, isOnline, isStopped, isStopping, login, main, movedRegionCleanerPeriod, postOpenDeployTasks, postOpenDeployTasks, registerService, removeFromOnlineRegions, reportRegionStateTransition, reportRegionStateTransition, reportRegionStateTransition, sendShutdownInterrupt, setInitLatch, setupClusterConnection, shouldUseThisHostnameInstead, stop, stopServiceThreads, toString, tryRegionServerReport, updateConfiguration, updateRegionFavoredNodesMapping, waitForMasterActive, waitForServerOnlinegetName, getThread, interrupt, isAlive, isInterrupted, join, join, join, setDaemon, setName, setPriority, setUncaughtExceptionHandler, startpublic MyRegionServer(Configuration conf,
CoordinatedStateManager cp)
throws IOException,
KeeperException,
InterruptedException
IOExceptionKeeperExceptionInterruptedExceptionprotected ServerName createRegionServerStatusStub()
HRegionServercreateRegionServerStatusStub in class HRegionServerpublic boolean getRpcStubCreatedFlag()