public static class HMasterCommandLine.LocalHMaster extends HMaster
HMaster.RedirectServletHRegionServer.MovedRegionsCleanerRegionServerServices.PostOpenDeployContext, RegionServerServices.RegionStateTransitionContext| Modifier and Type | Field and Description |
|---|---|
private MiniZooKeeperCluster |
zkcluster |
assignmentManager, balancer, catalogJanitorChore, coprocessorServiceHandlers, cpHost, loadBalancerTracker, MASTER, metricsMaster, mpmHost, regionServerTracker, rsFatals, serverManager, serviceStarted, snapshotManagercacheConfig, cacheFlusher, CLOSE, clusterConnection, clusterStatusTracker, compactSplitThread, conf, configurationManager, csm, fs, fsOk, hMemManager, infoServer, leases, lock, MASTER_HOSTNAME_KEY, metaTableLocator, movedRegions, msgInterval, numRegionsToReport, onlineRegions, OPEN, recoveringRegions, regionFavoredNodesMap, REGIONSERVER, regionsInTransitionInRS, replicationSinkHandler, replicationSourceHandler, rpcServices, serverName, service, sleeper, startcode, tableDescriptors, tableLockManager, threadWakeFrequency, useThisHostnameInstead, walFactory, zooKeeper| Constructor and Description |
|---|
HMasterCommandLine.LocalHMaster(org.apache.hadoop.conf.Configuration conf,
CoordinatedStateManager csm) |
| Modifier and Type | Method and Description |
|---|---|
void |
run()
The HRegionServer sticks in this loop until closed.
|
(package private) void |
setZKCluster(MiniZooKeeperCluster zkcluster) |
abort, abortProcedure, addColumn, assignMeta, assignRegion, balance, balanceSwitch, canCreateBaseZNode, canUpdateTableDescriptor, checkInitialized, checkNamespaceManagerReady, checkServiceStarted, checkTableModifiable, configureInfoServer, constructMaster, createCatalogJanitor, createNamespace, createRpcServices, createServerManager, createTable, deleteColumn, deleteNamespace, deleteTable, disableTable, dispatchMergingRegions, enableTable, ensureNamespaceExists, getAssignmentManager, getAverageLoad, getClientIdAuditPrefix, getClusterStatus, getDumpServlet, getHFileCleaner, getInitializedEvent, getLastMajorCompactionTimestamp, getLastMajorCompactionTimestampForRegion, getLoadBalancerClassName, getLoadedCoprocessors, getMasterActiveTime, getMasterCoprocessorHost, getMasterCoprocessors, getMasterFileSystem, getMasterMetrics, getMasterProcedureExecutor, getMasterQuotaManager, getMasterRpcServices, getMasterStartTime, getNamespaceDescriptor, getProcessName, getRegionNormalizerTracker, getRegionServerFatalLogBuffer, getRegionServerInfoPort, getRegionServerVersion, getRemoteInetAddress, getServerCrashProcessingEnabledEvent, getServerManager, getServerName, getSnapshotManager, getTableDescriptors, getTableRegionForRow, getZooKeeper, initializeZKBasedSystemTrackers, initNamespace, isActiveMaster, isBalancerOn, isCatalogJanitorEnabled, isInitializationStartsMetaRegionAssignment, isInitialized, isNormalizerOn, isServerCrashProcessingEnabled, listNamespaceDescriptors, listProcedures, listTableDescriptors, listTableDescriptorsByNamespace, listTableNames, listTableNamesByNamespace, login, main, modifyColumn, modifyNamespace, modifyTable, move, normalizeRegions, registerService, sendShutdownInterrupt, setCatalogJanitorEnabled, setInitialized, setServerCrashProcessingEnabled, shutdown, stopMaster, stopServiceThreads, truncateTable, waitForMasterActiveabort, addToMovedRegions, addToOnlineRegions, checkFileSystem, cleanMovedRegions, closeAllRegions, closeRegion, constructRegionServer, convertThrowableToIOE, createClusterConnection, createRegionLoad, createRegionServerStatusStub, createRegionServerStatusStub, ensureMetaWALRoller, execRegionServerService, getCacheConfig, getChoreService, getClusterId, getCompactionPressure, getCompactionRequester, getCompactSplitThread, getConfiguration, getConfigurationManager, getConnection, getCoordinatedStateManager, getExecutorService, getFavoredNodesForRegion, getFileSystem, getFlushRequester, getFromOnlineRegions, getHeapMemoryManager, getInfoServer, getLastSequenceId, getLeases, getMasterAddressTracker, getMetaTableLocator, getMostLoadedRegions, getNonceManager, getNumberOfOnlineRegions, getOnlineRegion, getOnlineRegions, getOnlineRegionsLocalContext, getOnlineTables, getRecoveringRegions, getRegion, getRegionBlockLocations, getRegionByEncodedName, getRegionByEncodedName, getRegionServerAccounting, getRegionServerCoprocessorHost, getRegionServerCoprocessors, getRegionServerMetrics, getRegionServerQuotaManager, getRegionsInTransitionInRS, getReplicationSourceService, getRootDir, getRpcServer, getRSRpcServices, getStartcode, getTableLockManager, getThreadWakeFrequency, getWAL, handleReportForDutyResponse, isAborted, isOnline, isStopped, isStopping, kill, movedRegionCleanerPeriod, postOpenDeployTasks, postOpenDeployTasks, removeFromOnlineRegions, reportRegionStateTransition, reportRegionStateTransition, reportRegionStateTransition, setupClusterConnection, shouldUseThisHostnameInstead, stop, stop, toString, tryRegionServerReport, updateConfiguration, updateRegionFavoredNodesMapping, waitForServerOnline, walRollRequestFinishedgetName, getThread, interrupt, isAlive, isInterrupted, join, join, join, setDaemon, setName, setPriority, setUncaughtExceptionHandler, startclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetExecutorService, getTableLockManagergetChoreService, getConfiguration, getConnection, getCoordinatedStateManager, getMetaTableLocatorprivate MiniZooKeeperCluster zkcluster
public HMasterCommandLine.LocalHMaster(org.apache.hadoop.conf.Configuration conf,
CoordinatedStateManager csm)
throws IOException,
org.apache.zookeeper.KeeperException,
InterruptedException
IOExceptionorg.apache.zookeeper.KeeperExceptionInterruptedExceptionpublic void run()
HRegionServerrun in interface Runnablerun in class HRegionServervoid setZKCluster(MiniZooKeeperCluster zkcluster)
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.