alluxio.master.journal

Interface JournalMaster

All Superinterfaces:

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

All Known Implementing Classes:

DefaultJournalMaster

public interface JournalMaster
extends Master

Interface for journal master implementations.

Field Summary

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

LOG

Method Summary

Modifier and Type	Method and Description
GetNodeStatePResponse	getNodeState() Gets the node state.
GetQuorumInfoPResponse	getQuorumInfo() Quorum information for participating servers in journal.
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 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, getName, getServices, start, stop

Method Detail

getQuorumInfo

GetQuorumInfoPResponse getQuorumInfo()
                              throws IOException

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

Returns:

the quorum info

Throws:

IOException - if error occurs while performing the operation

removeQuorumServer

void removeQuorumServer(NetAddress serverAddress)
                 throws IOException

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

Parameters:

serverAddress - server address to remove from quorum

Throws:

IOException - if error occurs while performing the operation

transferLeadership

String transferLeadership(NetAddress newLeaderAddress)

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

Parameters:

newLeaderAddress - server address to remove from quorum

Returns:

an error message if an error occurred, otherwise empty string

resetPriorities

void resetPriorities()
              throws IOException

Resets RaftPeer priorities.

Throws:

IOException - if error occurs while performing the operation

getNodeState

GetNodeStatePResponse getNodeState()

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.

Returns:

whether the node is a primary or standby