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.UncaughtExceptionHandlerNested 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, zooKeeperFields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected org.apache.hadoop.hbase.regionserver.RSRpcServicesMethods 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, walRollRequestFinishedMethods 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, yieldMethods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.apache.hadoop.hbase.Abortable
abort
-
Constructor Details
-
HeartbeatHRegionServer
public HeartbeatHRegionServer(org.apache.hadoop.conf.Configuration conf) throws IOException, InterruptedException - Throws:
IOExceptionInterruptedException
-
-
Method Details
-
createRpcServices
- Overrides:
createRpcServicesin classorg.apache.hadoop.hbase.regionserver.HRegionServer- Throws:
IOException
-