private static class TestScannerHeartbeatMessages.HeartbeatHRegionServer extends org.apache.hadoop.hbase.regionserver.HRegionServer
TestScannerHeartbeatMessages.HeartbeatRPCServices
in place of
RSRpcServices
to allow us to toggle support for heartbeat messagesThread.State, Thread.UncaughtExceptionHandler
ABORT_TIMEOUT, ABORT_TIMEOUT_TASK, compactedFileDischarger, metricsRegionServerImpl, nonceManager, online, REGIONSERVER, RS_HOSTNAME_DISABLE_MASTER_REVERSEDNS_KEY, TEST_SKIP_REPORTING_TRANSITION, 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 |
---|
HeartbeatHRegionServer(org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.hadoop.hbase.regionserver.RSRpcServices |
createRpcServices() |
abort, addRegion, buildRegionSpaceUseReportRequest, cacheTableDescriptor, canCreateBaseZNode, canUpdateTableDescriptor, checkFileSystem, clearRegionBlockCache, closeRegion, clusterMode, configureInfoServer, constructRegionServer, convertRegionSize, createNamedQueueRecord, createRegionLoad, createRegionLoad, createRegionServerStatusStub, dumpRowLocks, execRegionServerService, executeProcedure, finishRegionProcedure, getActiveMaster, getBackupMasters, getBlockCache, getBootstrapNodes, getBrokenStoreFileCleaner, getClusterId, getCompactedHFilesDischarger, getCompactionPressure, getCompactionRequestor, getCompactSplitThread, 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, handleReportForDutyResponse, isClusterUp, isDataFileSystemOk, isOnline, kill, login, main, movedRegionCacheExpiredTime, onConfigurationChange, postOpenDeployTasks, regionLock, registerService, remoteProcedureComplete, removeFromMovedRegions, removeRegion, reportFileArchivalForQuotas, reportProcedureDone, reportRegionSizesForQuotas, reportRegionStateTransition, run, 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
public HeartbeatHRegionServer(org.apache.hadoop.conf.Configuration conf) throws IOException, InterruptedException
IOException
InterruptedException
protected org.apache.hadoop.hbase.regionserver.RSRpcServices createRpcServices() throws IOException
createRpcServices
in class org.apache.hadoop.hbase.regionserver.HRegionServer
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.