alluxio.master

Class PrimarySelectorClient

java.lang.Object

alluxio.master.AbstractPrimarySelector

alluxio.master.PrimarySelectorClient

All Implemented Interfaces:

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

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

Masters use this client to elect a leader.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	PrimarySelectorClient.ZookeeperConnectionErrorPolicy Defines supported connection error policies for leader election.

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

PrimarySelector.Factory, PrimarySelector.State

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	close()
String	getName()
List<String>	getParticipants()
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, 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

PrimarySelectorClient

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

Constructs a new PrimarySelectorClient.

Parameters:

zookeeperAddress - the address to Zookeeper

electionPath - the election path

leaderPath - the path of the leader

Method Detail

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

stop

public void stop()
          throws IOException

Description copied from interface: PrimarySelector

Stops the primary selector.

Specified by:

stop in interface PrimarySelector

Throws:

IOException

getName

public String getName()

Returns:

the leader name

getParticipants

public List<String> getParticipants()

Returns:

the list of participants

start

public void start(InetSocketAddress address)
           throws IOException

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

Throws:

IOException

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