public static class TestRegionServerReportForDuty.MyRegionServer extends SingleProcessHBaseCluster.MiniHBaseClusterRegionServer
Thread.State, Thread.UncaughtExceptionHandler
Modifier and Type | Field and Description |
---|---|
private boolean |
masterChanged |
private boolean |
rpcStubCreatedFlag |
private org.apache.hadoop.hbase.ServerName |
sn |
ABORT_TIMEOUT, ABORT_TIMEOUT_TASK, compactedFileDischarger, metricsRegionServerImpl, nonceManager, online, REGIONSERVER, RS_HOSTNAME_DISABLE_MASTER_REVERSEDNS_KEY, TEST_SKIP_REPORTING_TRANSITION, unitKB, unitMB, UNSAFE_RS_HOSTNAME_DISABLE_MASTER_REVERSEDNS_KEY
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 |
---|
MyRegionServer(org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.hadoop.hbase.ServerName |
createRegionServerStatusStub(boolean refresh) |
boolean |
getRpcStubCreatedFlag() |
abort, handleReportForDutyResponse, kill, run
addRegion, buildRegionSpaceUseReportRequest, cacheTableDescriptor, canCreateBaseZNode, canUpdateTableDescriptor, checkFileSystem, clearRegionBlockCache, closeRegion, clusterMode, configureInfoServer, constructRegionServer, convertRegionSize, createNamedQueueRecord, createRegionLoad, createRegionLoad, createRpcServices, dumpRowLocks, execRegionServerService, executeProcedure, finishRegionProcedure, getActiveMaster, getBackupMasters, getBlockCache, getBootstrapNodes, getBrokenStoreFileCleaner, getClusterId, getCompactedHFilesDischarger, getCompactionPressure, getCompactionRequestor, getCompactSplitThread, getCoprocessorHost, getCopyOfOnlineRegionsSortedByOffHeapSize, getCopyOfOnlineRegionsSortedByOnHeapSize, 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, getRsSnapshotVerifier, getSecureBulkLoadManager, getUseThisHostnameInstead, getWAL, getWalFactory, getWalGroupsReplicationStatus, getWalRoller, getWALs, isClusterUp, isDataFileSystemOk, isOnline, isStopping, login, main, movedRegionCacheExpiredTime, onConfigurationChange, postOpenDeployTasks, regionLock, registerService, remoteProcedureComplete, removeFromMovedRegions, removeRegion, reportFileArchivalForQuotas, reportProcedureDone, reportRegionSizesForQuotas, reportRegionStateTransition, stop, stop, stopChores, stopServiceThreads, submitRegionProcedure, 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
private org.apache.hadoop.hbase.ServerName sn
private boolean rpcStubCreatedFlag
private boolean masterChanged
public MyRegionServer(org.apache.hadoop.conf.Configuration conf) throws IOException, org.apache.zookeeper.KeeperException, InterruptedException
IOException
org.apache.zookeeper.KeeperException
InterruptedException
protected org.apache.hadoop.hbase.ServerName createRegionServerStatusStub(boolean refresh)
createRegionServerStatusStub
in class org.apache.hadoop.hbase.regionserver.HRegionServer
public boolean getRpcStubCreatedFlag()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.