alluxio.master.journal.ufs

Class UfsJournalMultiMasterPrimarySelector

java.lang.Object

alluxio.master.AbstractPrimarySelector

alluxio.master.journal.ufs.UfsJournalMultiMasterPrimarySelector

All Implemented Interfaces:

PrimarySelector, org.apache.curator.framework.recipes.leader.LeaderSelectorListener, org.apache.curator.framework.state.ConnectionStateListener

@NotThreadSafe
public final class UfsJournalMultiMasterPrimarySelector
extends AbstractPrimarySelector
implements org.apache.curator.framework.recipes.leader.LeaderSelectorListener

Masters use this client to elect a leader.

Nested Class Summary

Nested classes/interfaces inherited from interface alluxio.master.PrimarySelector

PrimarySelector.Factory

Constructor Summary

Constructors

Constructor and Description
UfsJournalMultiMasterPrimarySelector(String zookeeperAddress, String electionPath, String leaderPath) Constructs a new UfsJournalMultiMasterPrimarySelector.

Method Summary

Modifier and Type	Method and Description
String	getName()
void	start(InetSocketAddress address) Starts the leader selection.
void	stateChanged(org.apache.curator.framework.CuratorFramework client, org.apache.curator.framework.state.ConnectionState newState)
void	stop() Stops the primary selector.
void	takeLeadership(org.apache.curator.framework.CuratorFramework client)

Methods inherited from class alluxio.master.AbstractPrimarySelector

getState, getStateUnsafe, onStateChange, setState, waitForState

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.curator.framework.state.ConnectionStateListener

doNotDecorate

Constructor Detail

UfsJournalMultiMasterPrimarySelector

public UfsJournalMultiMasterPrimarySelector(String zookeeperAddress,
                                            String electionPath,
                                            String leaderPath)

Constructs a new UfsJournalMultiMasterPrimarySelector.

Parameters:

zookeeperAddress - the address to Zookeeper

electionPath - the election path

leaderPath - the path of the leader

Method Detail

stop

public void stop()

Description copied from interface: PrimarySelector

Stops the primary selector.

Specified by:

stop in interface PrimarySelector

getName

public String getName()

Returns:

the leader name

start

public void start(InetSocketAddress address)

Starts the leader selection. If the leader selector client loses connection to Zookeeper or gets closed, the calling thread will be interrupted.

Specified by:

start in interface PrimarySelector

Parameters:

address - the address of the local master

stateChanged

public void stateChanged(org.apache.curator.framework.CuratorFramework client,
                         org.apache.curator.framework.state.ConnectionState newState)

Specified by:

stateChanged in interface org.apache.curator.framework.state.ConnectionStateListener

takeLeadership

public void takeLeadership(org.apache.curator.framework.CuratorFramework client)
                    throws Exception

Specified by:

takeLeadership in interface org.apache.curator.framework.recipes.leader.LeaderSelectorListener

Throws:

Exception