Class TestScannerHeartbeatMessages.HeartbeatHRegionServer
java.lang.Object
java.lang.Thread
org.apache.hadoop.hbase.regionserver.HRegionServer
org.apache.hadoop.hbase.regionserver.TestScannerHeartbeatMessages.HeartbeatHRegionServer
- All Implemented Interfaces:
Runnable
,org.apache.hadoop.hbase.Abortable
,org.apache.hadoop.hbase.conf.ConfigurationObserver
,org.apache.hadoop.hbase.regionserver.FavoredNodesForRegion
,org.apache.hadoop.hbase.regionserver.LastSequenceId
,org.apache.hadoop.hbase.regionserver.MutableOnlineRegions
,org.apache.hadoop.hbase.regionserver.OnlineRegions
,org.apache.hadoop.hbase.regionserver.RegionServerServices
,org.apache.hadoop.hbase.Server
,org.apache.hadoop.hbase.Stoppable
- Enclosing class:
- TestScannerHeartbeatMessages
private static class TestScannerHeartbeatMessages.HeartbeatHRegionServer
extends org.apache.hadoop.hbase.regionserver.HRegionServer
Custom HRegionServer instance that instantiates
TestScannerHeartbeatMessages.HeartbeatRPCServices
in place of
RSRpcServices
to allow us to toggle support for heartbeat messages-
Nested Class Summary
Nested classes/interfaces inherited from class java.lang.Thread
Thread.State, Thread.UncaughtExceptionHandler
Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.regionserver.RegionServerServices
org.apache.hadoop.hbase.regionserver.RegionServerServices.PostOpenDeployContext, org.apache.hadoop.hbase.regionserver.RegionServerServices.RegionStateTransitionContext
-
Field Summary
Fields inherited from class org.apache.hadoop.hbase.regionserver.HRegionServer
ABORT_TIMEOUT, ABORT_TIMEOUT_TASK, clusterConnection, clusterId, clusterStatusTracker, compactedFileDischarger, conf, configurationManager, executorService, infoServer, metricsRegionServerImpl, msgInterval, nonceManager, online, REGIONSERVER, rpcServices, RS_HOSTNAME_DISABLE_MASTER_REVERSEDNS_KEY, serverName, sleeper, startcode, tableDescriptors, TEST_SKIP_REPORTING_TRANSITION, unitKB, unitMB, UNSAFE_RS_HOSTNAME_DISABLE_MASTER_REVERSEDNS_KEY, useThisHostnameInstead, zooKeeper
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected org.apache.hadoop.hbase.regionserver.RSRpcServices
Methods inherited from class org.apache.hadoop.hbase.regionserver.HRegionServer
abort, addRegion, buildRegionSpaceUseReportRequest, cacheTableDescriptor, canCreateBaseZNode, canUpdateTableDescriptor, checkFileSystem, clearRegionBlockCache, closeRegion, configureInfoServer, constructRegionServer, convertRegionSize, createClusterConnection, createConnection, createRegionLoad, createRegionLoad, createRegionServerStatusStub, dumpRowLocks, execRegionServerService, executeProcedure, finishRegionProcedure, getAccessChecker, getActiveMaster, getBackupMasters, getBlockCache, getBootstrapNodes, getBrokenStoreFileCleaner, 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, getMetaRegionLocationCache, getMetrics, getMobFileCache, getMovedRegion, getNamedQueueRecorder, getNonceManager, getNumberOfOnlineRegions, getOnlineRegion, getOnlineRegions, getOnlineRegionsLocalContext, getOnlineTables, getProcessName, getRegion, getRegion, getRegionByEncodedName, getRegions, getRegions, getRegionServerAccounting, getRegionServerCoprocessorHost, getRegionServerCoprocessors, getRegionServerRpcQuotaManager, getRegionServerSpaceQuotaManager, getRegionsInTransitionInRS, getReplicationSinkService, getReplicationSourceService, getRetryPauseTime, getRpcServer, getRSMobFileCleanerChore, getRSRpcServices, getRsSnapshotVerifier, getSecureBulkLoadManager, getServerName, getStartcode, getTableDescriptors, getUseThisHostnameInstead, getWAL, getWalFactory, getWALFileSystem, getWalGroupsReplicationStatus, getWalRoller, getWALRootDir, getWALs, getZKPermissionWatcher, getZooKeeper, handleReportForDutyResponse, initializeMemStoreChunkCreator, isAborted, isClusterUp, isDataFileSystemOk, isOnline, isShutDown, isShutdownHookInstalled, isStopped, isStopping, kill, login, main, movedRegionCacheExpiredTime, onConfigurationChange, postOpenDeployTasks, postUpdateConfiguration, preUpdateConfiguration, regionLock, registerService, remoteProcedureComplete, removeFromMovedRegions, removeRegion, reportFileArchivalForQuotas, reportProcedureDone, reportRegionSizesForQuotas, reportRegionStateTransition, run, setAbortRequested, setupClusterConnection, shutdownChore, stop, stop, stopServiceThreads, submitRegionProcedure, toString, tryRegionServerReport, unassign, updateConfiguration, updateRegionFavoredNodesMapping, waitForMasterActive, waitForServerOnline, walRollRequestFinished
Methods inherited from class java.lang.Thread
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
Methods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface org.apache.hadoop.hbase.Abortable
abort
-
Constructor Details
-
HeartbeatHRegionServer
public HeartbeatHRegionServer(org.apache.hadoop.conf.Configuration conf) throws IOException, InterruptedException - Throws:
IOException
InterruptedException
-
-
Method Details
-
createRpcServices
- Overrides:
createRpcServices
in classorg.apache.hadoop.hbase.regionserver.HRegionServer
- Throws:
IOException
-