alluxio.master.meta

Class DefaultMetaMaster

java.lang.Object

alluxio.master.AbstractMaster

alluxio.master.meta.DefaultMetaMaster

All Implemented Interfaces:

JournalEntryIterable, JournalEntryStateMachine, Master, MetaMaster, Server<Boolean>

@NotThreadSafe
public final class DefaultMetaMaster
extends AbstractMaster
implements MetaMaster

The default meta master.

Field Summary

Fields inherited from class alluxio.master.AbstractMaster

mBackupManager, mPauseStateLock, mStateChangeLock

Method Summary

Modifier and Type	Method and Description
BackupResponse	backup(BackupOptions options) Backs up the master.
ConfigCheckReport	getConfigCheckReport()
List<ConfigProperty>	getConfiguration(GetConfigurationOptions options)
Set<Class<? extends Server>>	getDependencies()
Iterator<Journal.JournalEntry>	getJournalEntryIterator()
List<Address>	getMasterAddresses()
long	getMasterId(Address address) Returns a master id for the given master, creating one if the master is new.
String	getName()
InetSocketAddress	getRpcAddress()
Map<String,org.apache.thrift.TProcessor>	getServices()
long	getStartTimeMs()
long	getUptimeMs()
int	getWebPort()
List<Address>	getWorkerAddresses()
boolean	isInSafeMode()
MetaCommand	masterHeartbeat(long masterId) A standby master periodically heartbeats with the leader master.
void	masterRegister(long masterId, RegisterMasterTOptions options) A standby master registers with the leader master.
void	processJournalEntry(Journal.JournalEntry entry) Applies a journal entry to the state machine.
void	resetState() Resets the journaled internal state of the state machine.
void	start(Boolean isPrimary) Starts the Alluxio server.
void	stop() Stops the Alluxio server.

Methods inherited from class alluxio.master.AbstractMaster

createJournalContext, getExecutorService

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.master.Master

createJournalContext

Method Detail

getServices

public Map<String,org.apache.thrift.TProcessor> getServices()

Specified by:

getServices in interface Server<Boolean>

Returns:

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

getName

public String getName()

Specified by:

getName in interface JournalEntryStateMachine

Specified by:

getName in interface Server<Boolean>

Returns:

the name of this journal entry state machine

getDependencies

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

Specified by:

getDependencies in interface Server<Boolean>

Overrides:

getDependencies in class AbstractMaster

Returns:

the server dependencies

processJournalEntry

public void processJournalEntry(Journal.JournalEntry entry)
                         throws IOException

Description copied from interface: JournalEntryStateMachine

Applies a journal entry to the state machine.

Specified by:

processJournalEntry in interface JournalEntryStateMachine

Parameters:

entry - the entry to process to update the state of the state machine

Throws:

IOException

resetState

public void resetState()

Description copied from interface: JournalEntryStateMachine

Resets the journaled internal state of the state machine.

Specified by:

resetState in interface JournalEntryStateMachine

getJournalEntryIterator

public Iterator<Journal.JournalEntry> getJournalEntryIterator()

Specified by:

getJournalEntryIterator in interface JournalEntryIterable

Returns:

an Iterator that iterates all the journal entries

start

public void start(Boolean isPrimary)
           throws IOException

Description copied from interface: Server

Starts the Alluxio server.

Specified by:

start in interface Server<Boolean>

Overrides:

start in class AbstractMaster

Parameters:

isPrimary - the start options

Throws:

IOException

stop

public void stop()
          throws IOException

Description copied from interface: Server

Stops the Alluxio server. Here, anything created or started in #start(T) should be cleaned up and shutdown.

Specified by:

stop in interface Server<Boolean>

Overrides:

stop in class AbstractMaster

Throws:

IOException

backup

public BackupResponse backup(BackupOptions options)
                      throws IOException

Description copied from interface: MetaMaster

Backs up the master.

Specified by:

backup in interface MetaMaster

Parameters:

options - method options

Returns:

the uri of the created backup

Throws:

IOException

getConfigCheckReport

public ConfigCheckReport getConfigCheckReport()

Specified by:

getConfigCheckReport in interface MetaMaster

Returns:

the server-side configuration checker report

getConfiguration

public List<ConfigProperty> getConfiguration(GetConfigurationOptions options)

Specified by:

getConfiguration in interface MetaMaster

Parameters:

options - method options

Returns:

configuration information list

getMasterAddresses

public List<Address> getMasterAddresses()

Specified by:

getMasterAddresses in interface MetaMaster

Returns:

the addresses of live masters

getWorkerAddresses

public List<Address> getWorkerAddresses()

Specified by:

getWorkerAddresses in interface MetaMaster

Returns:

the addresses of live workers

getMasterId

public long getMasterId(Address address)

Description copied from interface: MetaMaster

Returns a master id for the given master, creating one if the master is new.

Specified by:

getMasterId in interface MetaMaster

Parameters:

address - the master hostname

Returns:

the master id for this master

getRpcAddress

public InetSocketAddress getRpcAddress()

Specified by:

getRpcAddress in interface MetaMaster

Returns:

this master's rpc address

getStartTimeMs

public long getStartTimeMs()

Specified by:

getStartTimeMs in interface MetaMaster

Returns:

the start time of the master in milliseconds

getUptimeMs

public long getUptimeMs()

Specified by:

getUptimeMs in interface MetaMaster

Returns:

the uptime of the master in milliseconds

getWebPort

public int getWebPort()

Specified by:

getWebPort in interface MetaMaster

Returns:

the master's web port

isInSafeMode

public boolean isInSafeMode()

Specified by:

isInSafeMode in interface MetaMaster

Returns:

true if Alluxio is running in safe mode, false otherwise

masterHeartbeat

public MetaCommand masterHeartbeat(long masterId)

Description copied from interface: MetaMaster

A standby master periodically heartbeats with the leader master.

Specified by:

masterHeartbeat in interface MetaMaster

Parameters:

masterId - the master id

Returns:

an optional command for the standby master to execute

masterRegister

public void masterRegister(long masterId,
                           RegisterMasterTOptions options)
                    throws NotFoundException

Description copied from interface: MetaMaster

A standby master registers with the leader master.

Specified by:

masterRegister in interface MetaMaster

Parameters:

masterId - the master id of the standby master registering

options - the options that contains master configuration

Throws:

NotFoundException - if masterId cannot be found