public static class TestAssignmentManagerOnCluster.MyRegionServer extends MiniHBaseCluster.MiniHBaseClusterRegionServer
HRegionServer.MovedRegionsCleaner
RegionServerServices.PostOpenDeployContext, RegionServerServices.RegionStateTransitionContext
TEST_SKIP_CLOSE
cacheConfig, cacheFlusher, CLOSE, clusterConnection, clusterStatusTracker, compactSplitThread, conf, configurationManager, csm, fs, fsOk, hMemManager, infoServer, 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 |
---|---|
boolean |
isAborted()
Check if the server or client was aborted.
|
boolean |
reportRegionStateTransition(RegionServerStatusProtos.RegionStateTransition.TransitionCode code,
long openSeqNum,
HRegionInfo... hris)
Notify master that a handler requests to change a region state
|
abort, handleReportForDutyResponse, kill, run
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, 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, isOnline, isStopped, isStopping, login, main, movedRegionCleanerPeriod, postOpenDeployTasks, postOpenDeployTasks, registerService, removeFromOnlineRegions, reportRegionStateTransition, reportRegionStateTransition, sendShutdownInterrupt, setupClusterConnection, shouldUseThisHostnameInstead, stop, stopServiceThreads, toString, tryRegionServerReport, updateConfiguration, updateRegionFavoredNodesMapping, waitForMasterActive, waitForServerOnline
getName, getThread, interrupt, isAlive, isInterrupted, join, join, join, setDaemon, setName, setPriority, setUncaughtExceptionHandler, start
public MyRegionServer(Configuration conf, CoordinatedStateManager cp) throws IOException, KeeperException, InterruptedException
IOException
KeeperException
InterruptedException
public boolean reportRegionStateTransition(RegionServerStatusProtos.RegionStateTransition.TransitionCode code, long openSeqNum, HRegionInfo... hris)
RegionServerServices
reportRegionStateTransition
in interface RegionServerServices
reportRegionStateTransition
in class HRegionServer
public boolean isAborted()
Abortable
isAborted
in interface Abortable
isAborted
in class HRegionServer