alluxio.master.throttle

Class DefaultThrottleMaster

java.lang.Object

alluxio.master.AbstractMaster

alluxio.master.throttle.DefaultThrottleMaster

All Implemented Interfaces:

Checkpointed, Journaled, JournalEntryIterable, NoopJournaled, Master, Server<Boolean>

@ThreadSafe
public final class DefaultThrottleMaster
extends AbstractMaster
implements NoopJournaled

This service periodically monitors the system and throttles in case of busy.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DefaultThrottleMaster.ThrottleExecutor Collects and saves call home information during the heartbeat.

Field Summary

Fields inherited from class alluxio.master.AbstractMaster

mClock, mJournal, mMasterContext

Constructor Summary

Constructors

Constructor and Description
DefaultThrottleMaster(MasterRegistry registry, MasterContext masterContext) Creates a new instance of DefaultThrottleMaster.

Method Summary

Modifier and Type	Method and Description
Set<Class<? extends Server>>	getDependencies()
String	getName()
Map<ServiceType,GrpcService>	getServices()
void	setMaster(MasterProcess masterProcess) Sets the master to be used in DefaultThrottleMaster.ThrottleExecutor for throttling.
void	start(Boolean isLeader) Starts the Alluxio server.

Methods inherited from class alluxio.master.AbstractMaster

close, createJournalContext, getExecutorService, getMasterContext, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.master.journal.NoopJournaled

getCheckpointName, getJournalEntryIterator, processJournalEntry, resetState, restoreFromCheckpoint, writeToCheckpoint

Methods inherited from interface alluxio.master.journal.Journaled

applyAndJournal

Methods inherited from interface alluxio.master.Master

getStandbyServices

Constructor Detail

DefaultThrottleMaster

public DefaultThrottleMaster(MasterRegistry registry,
                             MasterContext masterContext)

Creates a new instance of DefaultThrottleMaster.

Parameters:

registry - the master registry

masterContext - the context for Alluxio master

Method Detail

setMaster

public void setMaster(MasterProcess masterProcess)

Sets the master to be used in DefaultThrottleMaster.ThrottleExecutor for throttling. This should be called before calling start(Boolean).

Parameters:

masterProcess - the Alluxio master process

getDependencies

public Set<Class<? extends Server>> getDependencies()

Specified by:

getDependencies in interface Server<Boolean>

Overrides:

getDependencies in class AbstractMaster

Returns:

the server dependencies

getName

public String getName()

Specified by:

getName in interface Server<Boolean>

Returns:

the server's name

start

public void start(Boolean isLeader)
           throws IOException

Description copied from interface: Server

Starts the Alluxio server.

Specified by:

start in interface Server<Boolean>

Overrides:

start in class AbstractMaster

Parameters:

isLeader - the start options

Throws:

IOException

getServices

public Map<ServiceType,GrpcService> getServices()

Specified by:

getServices in interface Server<Boolean>

Returns:

a map from service names to gRPC serviced that serve RPCs for this server