alluxio.master

Class LocalAlluxioMaster

java.lang.Object

alluxio.master.LocalAlluxioMaster

@NotThreadSafe
public final class LocalAlluxioMaster
extends Object

Constructs an isolated master. Primary users of this class are the LocalAlluxioCluster and MultiMasterLocalAlluxioCluster. Isolated is defined as having its own root directory, and port.

Method Summary

Modifier and Type	Method and Description
void	clearClients() Clears all the clients.
static LocalAlluxioMaster	create(boolean includeSecondary) Creates a new local Alluxio master with an isolated work directory and port.
static LocalAlluxioMaster	create(String workDirectory, boolean includeSecondary) Creates a new local Alluxio master with a isolated port.
InetSocketAddress	getAddress()
FileSystem	getClient()
FileSystem	getClient(FileSystemContext context)
String	getJournalFolder()
AlluxioMasterProcess	getMasterProcess()
int	getRpcLocalPort() Gets the actual port that the RPC service is listening on.
String	getUri()
boolean	isServing()
void	start() Starts the master.
void	stop() Stops the master processes and cleans up client connections.

Methods inherited from class java.lang.Object

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

Method Detail

create

public static LocalAlluxioMaster create(boolean includeSecondary)
                                 throws IOException

Creates a new local Alluxio master with an isolated work directory and port.

Parameters:

includeSecondary - whether to start a secondary master alongside the regular master

Returns:

an instance of Alluxio master

Throws:

IOException

create

public static LocalAlluxioMaster create(String workDirectory,
                                        boolean includeSecondary)
                                 throws IOException

Creates a new local Alluxio master with a isolated port.

Parameters:

workDirectory - Alluxio work directory, this method will create it if it doesn't exist yet

includeSecondary - whether to start a secondary master alongside the regular master

Returns:

the created Alluxio master

Throws:

IOException

start

public void start()

Starts the master.

isServing

public boolean isServing()

Returns:

true if the master is serving, false otherwise

stop

public void stop()
          throws Exception

Stops the master processes and cleans up client connections.

Throws:

Exception

clearClients

public void clearClients()
                  throws IOException

Clears all the clients.

Throws:

IOException

getAddress

public InetSocketAddress getAddress()

Returns:

the externally resolvable address of the master

getMasterProcess

public AlluxioMasterProcess getMasterProcess()

Returns:

the internal MasterProcess

getRpcLocalPort

public int getRpcLocalPort()

Gets the actual port that the RPC service is listening on.

Returns:

the RPC local port

getUri

public String getUri()

Returns:

the URI of the master

getClient

public FileSystem getClient()
                     throws IOException

Returns:

the client from the pool

Throws:

IOException

getClient

public FileSystem getClient(FileSystemContext context)
                     throws IOException

Parameters:

context - the FileSystemContext to use

Returns:

the client from the pool, using a specific context

Throws:

IOException

getJournalFolder

public String getJournalFolder()

Returns:

the folder of the journal