alluxio.master.journal

Class DefaultJournalMaster

java.lang.Object

alluxio.master.AbstractMaster

alluxio.master.journal.DefaultJournalMaster

All Implemented Interfaces:

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

public class DefaultJournalMaster
extends AbstractMaster
implements JournalMaster, NoopJournaled

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

Field Summary

Fields inherited from class alluxio.master.AbstractMaster

mClock, mJournal, mMasterContext

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

LOG

Constructor Summary

Constructors

Constructor and Description
DefaultJournalMaster(JournalDomain journalDomain, MasterContext masterContext)

Method Summary

Modifier and Type	Method and Description
String	getName()
GetNodeStatePResponse	getNodeState() Gets the node state.
GetQuorumInfoPResponse	getQuorumInfo() Quorum information for participating servers in journal.
Map<ServiceType,GrpcService>	getServices()
void	removeQuorumServer(NetAddress serverAddress) Removes a server from journal quorum.
void	resetPriorities() Resets RaftPeer priorities.
String	transferLeadership(NetAddress newLeaderAddress) Changes the leading master of the journal quorum.

Methods inherited from class alluxio.master.AbstractMaster

close, createJournalContext, getDependencies, getExecutorService, getMasterContext, start, 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.Master

createJournalContext, getMasterContext, getStandbyServices

Methods inherited from interface alluxio.master.journal.Journaled

applyAndJournal, processJournalEntry, resetState, restoreFromCheckpoint, writeToCheckpoint

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

getCheckpointName, restoreFromCheckpoint, writeToCheckpoint

Methods inherited from interface alluxio.master.journal.JournalEntryIterable

getJournalEntryIterator

Methods inherited from interface alluxio.Server

close, getDependencies, start, stop

Methods inherited from interface alluxio.master.journal.NoopJournaled

getCheckpointName, getJournalEntryIterator, processJournalEntry, resetState, restoreFromCheckpoint, restoreFromCheckpoint, writeToCheckpoint, writeToCheckpoint

Constructor Detail

DefaultJournalMaster

public DefaultJournalMaster(JournalDomain journalDomain,
                            MasterContext masterContext)

Parameters:

journalDomain - domain for the journal

masterContext - the context for Alluxio master

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 String transferLeadership(NetAddress newLeaderAddress)

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

Returns:

an error message if an error occurred, otherwise empty string

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

getNodeState

public GetNodeStatePResponse getNodeState()

Description copied from interface: JournalMaster

Gets the node state. This endpoint is available for both UFS and embedded journals. If HA mode is turn off, the node state will always be returned as PRIMARY.

Specified by:

getNodeState in interface JournalMaster

Returns:

whether the node is a primary or standby

getName

public String getName()

Specified by:

getName in interface Server<Boolean>

Returns:

the server's name

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