Modifier and Type | Field and Description |
---|---|
private MasterServices |
LogRollMasterProcedureManager.master |
Modifier and Type | Method and Description |
---|---|
void |
LogRollMasterProcedureManager.initialize(MasterServices master,
MetricsMaster metricsMaster) |
Modifier and Type | Field and Description |
---|---|
private MasterServices |
SplitLogManagerCoordination.SplitLogManagerDetails.master |
Modifier and Type | Method and Description |
---|---|
MasterServices |
SplitLogManagerCoordination.SplitLogManagerDetails.getMaster()
Returns the master value
|
Constructor and Description |
---|
SplitLogManagerDetails(ConcurrentMap<String,SplitLogManager.Task> tasks,
MasterServices master,
Set<String> failedDeletions) |
Modifier and Type | Method and Description |
---|---|
MasterServices |
HasMasterServices.getMasterServices()
Deprecated.
Returns An instance of RegionServerServices, an object NOT for Coprocessor consumption.
|
Modifier and Type | Class and Description |
---|---|
class |
HMaster
HMaster is the "master server" for HBase.
|
static class |
HMasterCommandLine.LocalHMaster |
Modifier and Type | Field and Description |
---|---|
private MasterServices |
TableStateManager.master |
private MasterServices |
SplitWALManager.master |
private MasterServices |
OldWALsDirSizeChore.master |
private MasterServices |
ServerManager.master |
private MasterServices |
WorkerAssigner.master |
private MasterServices |
ClusterSchemaServiceImpl.masterServices |
private MasterServices |
TableNamespaceManager.masterServices |
private MasterServices |
MasterCoprocessorHost.masterServices |
private MasterServices |
MasterCoprocessorHost.MasterEnvironmentForCoreCoprocessors.masterServices |
private MasterServices |
RegionServerTracker.server |
private MasterServices |
SplitLogManager.server
Deprecated.
|
private MasterServices |
MasterWalManager.services |
private MasterServices |
MasterCoprocessorHost.MasterEnvironment.services |
Modifier and Type | Method and Description |
---|---|
MasterServices |
MasterCoprocessorHost.MasterEnvironmentForCoreCoprocessors.getMasterServices() |
Modifier and Type | Method and Description |
---|---|
protected AssignmentManager |
HMaster.createAssignmentManager(MasterServices master,
MasterRegion masterRegion) |
protected ServerManager |
HMaster.createServerManager(MasterServices master,
RegionServerList storage)
Create a
ServerManager instance. |
Constructor and Description |
---|
ClusterSchemaServiceImpl(MasterServices masterServices) |
MasterCoprocessorHost(MasterServices services,
org.apache.hadoop.conf.Configuration conf) |
MasterEnvironment(MasterCoprocessor impl,
int priority,
int seq,
org.apache.hadoop.conf.Configuration conf,
MasterServices services) |
MasterEnvironmentForCoreCoprocessors(MasterCoprocessor impl,
int priority,
int seq,
org.apache.hadoop.conf.Configuration conf,
MasterServices services) |
MasterWalManager(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path rootDir,
MasterServices services) |
MasterWalManager(MasterServices services) |
OldWALsDirSizeChore(MasterServices master) |
RegionServerTracker(ZKWatcher watcher,
MasterServices server) |
ServerManager(MasterServices master,
RegionServerList storage)
Constructor.
|
SplitLogManager(MasterServices master,
org.apache.hadoop.conf.Configuration conf)
Deprecated.
Its OK to construct this object even when region-servers are not online.
|
SplitWALManager(MasterServices master) |
TableNamespaceManager(MasterServices masterServices) |
TableStateManager(MasterServices master) |
WorkerAssigner(MasterServices master,
int maxTasks,
ProcedureEvent<?> event) |
Modifier and Type | Field and Description |
---|---|
private MasterServices |
AssignmentManager.master |
private MasterServices |
RegionStateStore.master |
Modifier and Type | Method and Description |
---|---|
(package private) MasterServices |
AssignmentManager.getMaster() |
Constructor and Description |
---|
AssignmentManager(MasterServices master,
MasterRegion masterRegion) |
AssignmentManager(MasterServices master,
MasterRegion masterRegion,
RegionStateStore stateStore) |
RegionStateStore(MasterServices master,
MasterRegion masterRegion) |
Modifier and Type | Field and Description |
---|---|
private MasterServices |
MasterClusterInfoProvider.services |
Constructor and Description |
---|
MasterClusterInfoProvider(MasterServices services) |
Modifier and Type | Field and Description |
---|---|
private MasterServices |
HbckChore.master |
Constructor and Description |
---|
HbckChore(MasterServices master) |
Constructor and Description |
---|
ClusterMetricsResource(MasterServices master) |
Modifier and Type | Field and Description |
---|---|
private MasterServices |
MetaFixer.masterServices |
private MasterServices |
CatalogJanitor.services |
private MasterServices |
ReportMakingVisitor.services |
Modifier and Type | Method and Description |
---|---|
private static Pair<Boolean,Boolean> |
CatalogJanitor.checkRegionReferences(MasterServices services,
TableName tableName,
RegionInfo region)
Checks if a region still holds references to parent.
|
(package private) static boolean |
CatalogJanitor.cleanMergeRegion(MasterServices services,
RegionInfo mergedRegion,
List<RegionInfo> parents)
If merged region no longer holds reference to the merge regions, archive merge region on hdfs
and perform deleting references in hbase:meta
|
(package private) static boolean |
CatalogJanitor.cleanParent(MasterServices services,
RegionInfo parent,
Result rowContent) |
private static List<RegionInfo> |
MetaFixer.createMetaEntries(MasterServices masterServices,
List<RegionInfo> newRegionInfos)
Create entries in the
hbase:meta for each provided RegionInfo . |
Constructor and Description |
---|
CatalogJanitor(MasterServices services) |
MetaFixer(MasterServices masterServices) |
ReportMakingVisitor(MasterServices services) |
Constructor and Description |
---|
RollingUpgradeChore(MasterServices masterServices) |
Modifier and Type | Field and Description |
---|---|
private MasterServices |
RegionNormalizerChore.master |
private MasterServices |
SimpleRegionNormalizer.masterServices |
private MasterServices |
RegionNormalizerWorker.masterServices |
Modifier and Type | Method and Description |
---|---|
void |
SimpleRegionNormalizer.setMasterServices(MasterServices masterServices) |
void |
RegionNormalizer.setMasterServices(MasterServices masterServices)
Set the master service.
|
Constructor and Description |
---|
RegionNormalizerChore(MasterServices master) |
RegionNormalizerWorker(org.apache.hadoop.conf.Configuration configuration,
MasterServices masterServices,
RegionNormalizer regionNormalizer,
RegionNormalizerWorkQueue<TableName> workQueue) |
Modifier and Type | Field and Description |
---|---|
protected MasterServices |
RSProcedureDispatcher.master |
private MasterServices |
MasterProcedureEnv.master |
private MasterServices |
MasterProcedureEnv.FsUtilsLeaseRecovery.master |
private MasterServices |
RecoverMetaProcedure.master
Deprecated.
|
private MasterServices |
MasterProcedureUtil.NonceProcedureRunnable.master |
Modifier and Type | Method and Description |
---|---|
protected MasterServices |
MasterProcedureUtil.NonceProcedureRunnable.getMaster() |
MasterServices |
MasterProcedureEnv.getMasterServices() |
Constructor and Description |
---|
FsUtilsLeaseRecovery(MasterServices master) |
MasterProcedureEnv(MasterServices master) |
MasterProcedureEnv(MasterServices master,
RSProcedureDispatcher remoteDispatcher) |
NonceProcedureRunnable(MasterServices master,
long nonceGroup,
long nonce) |
RSProcedureDispatcher(MasterServices master) |
Modifier and Type | Method and Description |
---|---|
static ReplicationPeerManager |
ReplicationPeerManager.create(MasterServices services,
String clusterId) |
private static Pair<ReplicationQueueStorage,ReplicationPeerManager.ReplicationQueueStorageInitializer> |
ReplicationPeerManager.createReplicationQueueStorage(MasterServices services) |
Constructor and Description |
---|
SyncReplicationReplayWALManager(MasterServices services) |
Modifier and Type | Field and Description |
---|---|
private MasterServices |
SlowLogMasterService.masterServices |
Constructor and Description |
---|
SlowLogMasterService(org.apache.hadoop.conf.Configuration configuration,
MasterServices masterServices) |
Modifier and Type | Field and Description |
---|---|
private MasterServices |
SnapshotManager.master |
protected MasterServices |
TakeSnapshotHandler.master |
private MasterServices |
SnapshotHFileCleaner.master |
private MasterServices |
MasterSnapshotVerifier.services |
Modifier and Type | Method and Description |
---|---|
void |
SnapshotManager.initialize(MasterServices master,
MetricsMaster metricsMaster) |
Constructor and Description |
---|
DisabledTableSnapshotHandler(org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription snapshot,
MasterServices masterServices,
SnapshotManager snapshotManager) |
EnabledTableSnapshotHandler(org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription snapshot,
MasterServices master,
SnapshotManager manager) |
MasterSnapshotVerifier(MasterServices services,
org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription snapshot,
org.apache.hadoop.fs.FileSystem workingDirFs) |
SnapshotManager(MasterServices master,
ProcedureCoordinator coordinator,
ExecutorService pool,
int sentinelCleanInterval)
Fully specify all necessary components of a snapshot manager.
|
TakeSnapshotHandler(org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription snapshot,
MasterServices masterServices,
SnapshotManager snapshotManager) |
Modifier and Type | Method and Description |
---|---|
static void |
WALEventTrackerTableCreator.createIfNeededAndNotExists(org.apache.hadoop.conf.Configuration conf,
MasterServices masterServices) |
Modifier and Type | Field and Description |
---|---|
private MasterServices |
NamespaceStateManager.master |
private MasterServices |
NamespaceAuditor.masterServices |
Constructor and Description |
---|
NamespaceAuditor(MasterServices masterServices) |
NamespaceStateManager(MasterServices masterServices) |
Modifier and Type | Method and Description |
---|---|
abstract void |
MasterProcedureManager.initialize(MasterServices master,
MetricsMaster metricsMaster)
Initialize a globally barriered procedure for master.
|
void |
MasterProcedureManagerHost.initialize(MasterServices master,
MetricsMaster metricsMaster) |
Modifier and Type | Field and Description |
---|---|
private MasterServices |
MasterFlushTableProcedureManager.master |
Modifier and Type | Method and Description |
---|---|
void |
MasterFlushTableProcedureManager.initialize(MasterServices master,
MetricsMaster metricsMaster) |
Modifier and Type | Field and Description |
---|---|
private MasterServices |
MasterQuotaManager.masterServices |
private MasterServices |
MasterQuotasObserver.masterServices |
Constructor and Description |
---|
MasterQuotaManager(MasterServices masterServices) |
Modifier and Type | Method and Description |
---|---|
static void |
ReplicationSinkTrackerTableCreator.createIfNeededAndNotExists(org.apache.hadoop.conf.Configuration conf,
MasterServices masterServices) |
private Set<ServerName> |
ReplicationLogCleaner.getNotFullyDeadServers(MasterServices services) |
Modifier and Type | Field and Description |
---|---|
private MasterServices |
RSGroupAdminEndpoint.master
Deprecated.
|
private MasterServices |
RSGroupAdminServiceImpl.master
Deprecated.
|
private MasterServices |
RSGroupBasedLoadBalancer.masterServices |
private MasterServices |
RSGroupInfoManagerImpl.masterServices |
Modifier and Type | Method and Description |
---|---|
static RSGroupInfoManager |
RSGroupInfoManager.create(MasterServices master) |
(package private) static RSGroupInfoManager |
RSGroupInfoManagerImpl.getInstance(MasterServices masterServices) |
static Optional<RSGroupInfo> |
RSGroupUtil.getRSGroupInfo(MasterServices master,
RSGroupInfoManager manager,
TableName tableName)
Will try to get the rsgroup from
TableDescriptor first, and then try to get the rsgroup
from the NamespaceDescriptor . |
(package private) void |
RSGroupAdminServiceImpl.initialize(MasterServices masterServices)
Deprecated.
|
private static boolean |
RSGroupInfoManagerImpl.isMasterRunning(MasterServices masterServices) |
static List<TableName> |
RSGroupUtil.listTablesInRSGroup(MasterServices master,
String groupName) |
void |
RSGroupBasedLoadBalancer.setMasterServices(MasterServices masterServices) |
Constructor and Description |
---|
RSGroupInfoManagerImpl(MasterServices masterServices) |
Modifier and Type | Field and Description |
---|---|
private MasterServices |
SnapshotScannerHDFSAclController.masterServices |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.