public static class TestRegionServerReportForDuty.MyRegionServer extends MiniHBaseCluster.MiniHBaseClusterRegionServer
org.apache.hadoop.hbase.regionserver.HRegionServer.MovedRegionsCleaner
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, clusterConnection, clusterId, clusterStatusTracker, compactedFileDischarger, compactSplitThread, conf, configurationManager, executorService, infoServer, metricsRegionServerImpl, msgInterval, nonceManager, online, REGIONSERVER, rpcServices, RS_HOSTNAME_DISABLE_MASTER_REVERSEDNS_KEY, serverName, sleeper, startcode, tableDescriptors, TEST_SKIP_REPORTING_TRANSITION, useThisHostnameInstead, 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
abort, addRegion, buildRegionSpaceUseReportRequest, canCreateBaseZNode, canUpdateTableDescriptor, checkFileSystem, cleanMovedRegions, clearRegionBlockCache, closeRegion, configureInfoServer, constructRegionServer, convertRegionSize, createClusterConnection, createConnection, createRegionLoad, createRegionLoad, createRpcServices, execRegionServerService, executeProcedure, finishRegionProcedure, getAccessChecker, getBlockCache, getChoreService, getClusterConnection, getClusterId, getCompactedHFilesDischarger, getCompactionPressure, getCompactionRequestor, getCompactSplitThread, getConfiguration, getConfigurationManager, getConnection, getCoordinatedStateManager, getCopyOfOnlineRegionsSortedByOffHeapSize, getCopyOfOnlineRegionsSortedByOnHeapSize, getDataRootDir, getDumpServlet, getEventLoopGroupConfig, getExecutorService, getFavoredNodesForRegion, getFileSystem, getFlushPressure, getFlushRequester, getFlushThroughputController, getHeapMemoryManager, getInfoServer, getLastSequenceId, getLeaseManager, getMasterAddressTracker, getMemStoreFlusher, getMetrics, getMobFileCache, getNonceManager, getNumberOfOnlineRegions, getOnlineRegion, getOnlineRegions, getOnlineRegionsLocalContext, getOnlineTables, getProcessName, getRegion, getRegion, getRegionByEncodedName, getRegions, getRegions, getRegionServerAccounting, getRegionServerCoprocessorHost, getRegionServerCoprocessors, getRegionServerRpcQuotaManager, getRegionServerSpaceQuotaManager, getRegionsInTransitionInRS, getReplicationSinkService, getReplicationSourceService, getRpcServer, getRSRpcServices, getSecureBulkLoadManager, getServerName, getSlowLogRecorder, getStartcode, getTableDescriptors, getUseThisHostnameInstead, getWAL, getWalFactory, getWALFileSystem, getWalGroupsReplicationStatus, getWalRoller, getWALRootDir, getWALs, getZKPermissionWatcher, getZooKeeper, initializeMemStoreChunkCreator, isAborted, isClusterUp, isDataFileSystemOk, isOnline, isShutDown, isStopped, isStopping, login, main, movedRegionCleanerPeriod, onConfigurationChange, postOpenDeployTasks, regionLock, registerService, remoteProcedureComplete, removeFromMovedRegions, removeRegion, reportFileArchivalForQuotas, reportProcedureDone, reportRegionSizesForQuotas, reportRegionStateTransition, setAbortRequested, setupClusterConnection, stop, stop, stopServiceThreads, submitRegionProcedure, toString, tryRegionServerReport, unassign, updateConfiguration, updateRegionFavoredNodesMapping, waitForMasterActive, waitForServerOnline, walRollRequestFinished
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
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.