alluxio.master.meta

Interface MetaMaster

All Superinterfaces:

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

All Known Implementing Classes:

DefaultMetaMaster

public interface MetaMaster
extends Master

The interface of meta master.

Method Summary

Modifier and Type	Method and Description
BackupResponse	backup(BackupPOptions options) Backs up the master.
String	checkpoint() Creates a checkpoint in the primary master journal system.
String	getClusterID()
ConfigCheckReport	getConfigCheckReport()
ConfigHash	getConfigHash()
Configuration	getConfiguration(GetConfigurationPOptions options)
List<Address>	getMasterAddresses()
long	getMasterId(Address address) Returns a master id for the given master, creating one if the master is new.
boolean	getNewerVersionAvailable()
InetSocketAddress	getRpcAddress()
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, RegisterMasterPOptions options) A standby master registers with the leader master.
void	removePathConfiguration(String path) Removes all properties for a path.
void	removePathConfiguration(String path, Set<String> keys) Removes properties for a path.
void	setPathConfiguration(String path, Map<PropertyKey,String> properties) Sets properties for a path.

Methods inherited from interface alluxio.master.Master

createJournalContext

Methods inherited from interface alluxio.master.journal.Journaled

applyAndJournal, processJournalEntry, resetState, restoreFromCheckpoint, writeToCheckpoint

Methods inherited from interface alluxio.master.journal.checkpoint.Checkpointed

getCheckpointName

Methods inherited from interface alluxio.master.journal.JournalEntryIterable

getJournalEntryIterator

Methods inherited from interface alluxio.Server

close, getDependencies, getName, getServices, start, stop

Method Detail

backup

BackupResponse backup(BackupPOptions options)
               throws IOException

Backs up the master.

Parameters:

options - method options

Returns:

the uri of the created backup

Throws:

IOException

getClusterID

String getClusterID()

Returns:

the cluster ID

getConfigCheckReport

ConfigCheckReport getConfigCheckReport()

Returns:

the server-side configuration checker report

getConfiguration

Configuration getConfiguration(GetConfigurationPOptions options)

Parameters:

options - method options

Returns:

configuration information list

getConfigHash

ConfigHash getConfigHash()

Returns:

hashes of cluster and path level configuration

setPathConfiguration

void setPathConfiguration(String path,
                          Map<PropertyKey,String> properties)
                   throws UnavailableException

Sets properties for a path.

Parameters:

path - the path

properties - the properties for path

Throws:

UnavailableException

removePathConfiguration

void removePathConfiguration(String path,
                             Set<String> keys)
                      throws UnavailableException

Removes properties for a path.

Parameters:

path - the path

keys - the property keys

Throws:

UnavailableException

removePathConfiguration

void removePathConfiguration(String path)
                      throws UnavailableException

Removes all properties for a path.

Parameters:

path - the path

Throws:

UnavailableException

getNewerVersionAvailable

boolean getNewerVersionAvailable()

Returns:

true if newer version is available, false otherwise

getMasterAddresses

List<Address> getMasterAddresses()

Returns:

the addresses of live masters

getMasterId

long getMasterId(Address address)

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

Parameters:

address - the master hostname

Returns:

the master id for this master

getRpcAddress

InetSocketAddress getRpcAddress()

Returns:

this master's rpc address

getStartTimeMs

long getStartTimeMs()

Returns:

the start time of the master in milliseconds

getUptimeMs

long getUptimeMs()

Returns:

the uptime of the master in milliseconds

getWebPort

int getWebPort()

Returns:

the master's web port

getWorkerAddresses

List<Address> getWorkerAddresses()

Returns:

the addresses of live workers

isInSafeMode

boolean isInSafeMode()

Returns:

true if Alluxio is running in safe mode, false otherwise

masterHeartbeat

MetaCommand masterHeartbeat(long masterId)

A standby master periodically heartbeats with the leader master.

Parameters:

masterId - the master id

Returns:

an optional command for the standby master to execute

masterRegister

void masterRegister(long masterId,
                    RegisterMasterPOptions options)
             throws NotFoundException

A standby master registers with the leader master.

Parameters:

masterId - the master id of the standby master registering

options - the options that contains master configuration

Throws:

NotFoundException - if masterId cannot be found

checkpoint

String checkpoint()
           throws IOException

Creates a checkpoint in the primary master journal system.

Returns:

the hostname of the master that did the checkpoint

Throws:

IOException