Package org.apache.hadoop.hbase.master.procedure

Class MasterProcedureEnv

java.lang.Object

org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv

All Implemented Interfaces:

ConfigurationObserver

@Private
@Evolving
public class MasterProcedureEnv
extends Object
implements ConfigurationObserver

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MasterProcedureEnv.FsUtilsLeaseRecovery

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG
private final MasterServices	master
private final MasterProcedureScheduler	procSched
private final RSProcedureDispatcher	remoteDispatcher

Constructor Summary

Constructors

Constructor	Description
MasterProcedureEnv(MasterServices master)
MasterProcedureEnv(MasterServices master, RSProcedureDispatcher remoteDispatcher)

Method Summary

Modifier and Type	Method	Description
AssignmentManager	getAssignmentManager()
ExecutorService	getAsyncTaskExecutor()	Get a thread pool for executing some asynchronous tasks
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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOG

private static final org.slf4j.Logger LOG

remoteDispatcher

private final RSProcedureDispatcher remoteDispatcher

procSched

private final MasterProcedureScheduler procSched

master

private final MasterServices master

Constructor Details

MasterProcedureEnv

public MasterProcedureEnv(MasterServices master)

MasterProcedureEnv

public MasterProcedureEnv(MasterServices master,
 RSProcedureDispatcher remoteDispatcher)

Method Details

getAsyncTaskExecutor

public ExecutorService getAsyncTaskExecutor()

Get a thread pool for executing some asynchronous tasks

getRequestUser

public User getRequestUser()

getMasterServices

public MasterServices getMasterServices()

getMasterConfiguration

public org.apache.hadoop.conf.Configuration getMasterConfiguration()

getAssignmentManager

public AssignmentManager getAssignmentManager()

getMasterCoprocessorHost

public MasterCoprocessorHost getMasterCoprocessorHost()

getProcedureScheduler

public MasterProcedureScheduler getProcedureScheduler()

getRemoteDispatcher

public RSProcedureDispatcher getRemoteDispatcher()

getReplicationPeerManager

public ReplicationPeerManager getReplicationPeerManager()

getMasterFileSystem

public MasterFileSystem getMasterFileSystem()

isRunning

public boolean isRunning()

isInitialized

public boolean isInitialized()

waitInitialized

public boolean waitInitialized(Procedure<?> proc)

setEventReady

public void setEventReady(ProcedureEvent<?> event,
 boolean isReady)

onConfigurationChange

public void onConfigurationChange(org.apache.hadoop.conf.Configuration conf)

Description copied from interface: ConfigurationObserver

This method would be called by the ConfigurationManager object when the Configuration object is reloaded from disk.

Specified by:

onConfigurationChange in interface ConfigurationObserver