@InterfaceAudience.Private @InterfaceStability.Evolving public class MasterProcedureEnv extends Object implements ConfigurationObserver
Modifier and Type | Class and Description |
---|---|
static class |
MasterProcedureEnv.WALStoreLeaseRecovery |
Modifier and Type | Field and Description |
---|---|
private static org.slf4j.Logger |
LOG |
private MasterServices |
master |
private MasterProcedureScheduler |
procSched |
private RSProcedureDispatcher |
remoteDispatcher |
Constructor and Description |
---|
MasterProcedureEnv(MasterServices master) |
MasterProcedureEnv(MasterServices master,
RSProcedureDispatcher remoteDispatcher) |
Modifier and Type | Method and Description |
---|---|
AssignmentManager |
getAssignmentManager() |
org.apache.hadoop.conf.Configuration |
getMasterConfiguration() |
MasterCoprocessorHost |
getMasterCoprocessorHost() |
MasterFileSystem |
getMasterFileSystem() |
MasterServices |
getMasterServices() |
MasterProcedureScheduler |
getProcedureScheduler() |
RSProcedureDispatcher |
getRemoteDispatcher() |
ReplicationPeerManager |
getReplicationPeerManager() |
User |
getRequestUser() |
boolean |
isInitialized() |
boolean |
isRunning() |
void |
onConfigurationChange(org.apache.hadoop.conf.Configuration conf)
This method would be called by the
ConfigurationManager
object when the Configuration object is reloaded from disk. |
void |
setEventReady(ProcedureEvent<?> event,
boolean isReady) |
boolean |
waitInitialized(Procedure<?> proc) |
private static final org.slf4j.Logger LOG
private final RSProcedureDispatcher remoteDispatcher
private final MasterProcedureScheduler procSched
private final MasterServices master
public MasterProcedureEnv(MasterServices master)
public MasterProcedureEnv(MasterServices master, RSProcedureDispatcher remoteDispatcher)
public User getRequestUser()
public MasterServices getMasterServices()
public org.apache.hadoop.conf.Configuration getMasterConfiguration()
public AssignmentManager getAssignmentManager()
public MasterCoprocessorHost getMasterCoprocessorHost()
public MasterProcedureScheduler getProcedureScheduler()
public RSProcedureDispatcher getRemoteDispatcher()
public ReplicationPeerManager getReplicationPeerManager()
public MasterFileSystem getMasterFileSystem()
public boolean isRunning()
public boolean isInitialized()
public boolean waitInitialized(Procedure<?> proc)
public void setEventReady(ProcedureEvent<?> event, boolean isReady)
public void onConfigurationChange(org.apache.hadoop.conf.Configuration conf)
ConfigurationObserver
ConfigurationManager
object when the Configuration
object is reloaded from disk.onConfigurationChange
in interface ConfigurationObserver
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.