alluxio.master.journal

Class DefaultJournalMaster

java.lang.Object

alluxio.master.journal.DefaultJournalMaster

All Implemented Interfaces:

JournalMaster

public class DefaultJournalMaster
extends Object
implements JournalMaster

Default implementation for JournalMaster. This is used by both master and job_master processes.

Constructor Summary

Constructors

Constructor and Description
DefaultJournalMaster(JournalDomain journalDomain, JournalSystem journalSystem)

Method Summary

Modifier and Type	Method and Description
GetQuorumInfoPResponse	getQuorumInfo() Quorum information for participating servers in journal.
void	removeQuorumServer(NetAddress serverAddress) Removes a server from journal quorum.
void	resetPriorities() Resets RaftPeer priorities.
void	transferLeadership(NetAddress newLeaderAddress) Changes the leading master of the journal quorum.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultJournalMaster

public DefaultJournalMaster(JournalDomain journalDomain,
                            JournalSystem journalSystem)

Parameters:

journalDomain - domain for the journal

journalSystem - internal JournalSystem reference

Method Detail

getQuorumInfo

public GetQuorumInfoPResponse getQuorumInfo()
                                     throws IOException

Description copied from interface: JournalMaster

Quorum information for participating servers in journal. This method is supported only for JournalType.EMBEDDED journal.

Specified by:

getQuorumInfo in interface JournalMaster

Returns:

the quorum info

Throws:

IOException - if error occurs while performing the operation

removeQuorumServer

public void removeQuorumServer(NetAddress serverAddress)
                        throws IOException

Description copied from interface: JournalMaster

Removes a server from journal quorum. This method is supported only for JournalType.EMBEDDED journal.

Specified by:

removeQuorumServer in interface JournalMaster

Parameters:

serverAddress - server address to remove from quorum

Throws:

IOException - if error occurs while performing the operation

transferLeadership

public void transferLeadership(NetAddress newLeaderAddress)
                        throws IOException

Description copied from interface: JournalMaster

Changes the leading master of the journal quorum. This method is supported only for JournalType.EMBEDDED journal.

Specified by:

transferLeadership in interface JournalMaster

Parameters:

newLeaderAddress - server address to remove from quorum

Throws:

IOException - if error occurs while performing the operation

resetPriorities

public void resetPriorities()
                     throws IOException

Description copied from interface: JournalMaster

Resets RaftPeer priorities.

Specified by:

resetPriorities in interface JournalMaster

Throws:

IOException - if error occurs while performing the operation