alluxio.client

Class RetryHandlingMetaMasterClient

java.lang.Object

alluxio.AbstractClient

alluxio.AbstractMasterClient

alluxio.client.RetryHandlingMetaMasterClient

All Implemented Interfaces:

Client, MetaMasterClient, Closeable, AutoCloseable

@ThreadSafe
public class RetryHandlingMetaMasterClient
extends AbstractMasterClient
implements MetaMasterClient

A wrapper for the thrift client to interact with the meta master. Since thrift clients are not thread safe, this class is a wrapper to provide thread safety and support for retries.

Nested Class Summary

Nested classes/interfaces inherited from class alluxio.AbstractClient

AbstractClient.RpcCallable<V>

Field Summary

Fields inherited from class alluxio.AbstractClient

mAddress, mClosed, mConnected, mProtocol, mServiceVersion

Constructor Summary

Constructors

Constructor and Description
RetryHandlingMetaMasterClient(MasterClientConfig conf) Creates a new meta master client.

Method Summary

Modifier and Type	Method and Description
protected void	afterConnect() This method is called after the connection is made to the remote.
BackupResponse	backup(String targetDirectory, boolean localFileSystem) Writes a backup of the journal to the specified directory.
protected AlluxioService.Client	getClient()
ConfigCheckReport	getConfigReport() Gets the server-side configuration check report.
List<ConfigProperty>	getConfiguration() Gets the runtime configuration information.
MasterInfo	getMasterInfo(Set<MasterInfo.MasterInfoField> fields)
Map<String,MetricValue>	getMetrics() Gets a map of metrics property names and their values from metrics system.
protected String	getServiceName()
protected long	getServiceVersion()

Methods inherited from class alluxio.AbstractMasterClient

getAddress

Methods inherited from class alluxio.AbstractClient

afterDisconnect, beforeDisconnect, checkVersion, close, connect, disconnect, isConnected, retryRPC, retryRPC

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.Closeable

close

Constructor Detail

RetryHandlingMetaMasterClient

public RetryHandlingMetaMasterClient(MasterClientConfig conf)

Creates a new meta master client.

Parameters:

conf - master client configuration

Method Detail

getClient

protected AlluxioService.Client getClient()

Specified by:

getClient in class AbstractClient

Returns:

a Thrift service client

getServiceName

protected String getServiceName()

Specified by:

getServiceName in class AbstractClient

Returns:

a string representing the specific service

getServiceVersion

protected long getServiceVersion()

Specified by:

getServiceVersion in class AbstractClient

Returns:

the client service version

afterConnect

protected void afterConnect()

Description copied from class: AbstractClient

This method is called after the connection is made to the remote. Implementations should create internal state to finish the connection process.

Overrides:

afterConnect in class AbstractClient

backup

public BackupResponse backup(String targetDirectory,
                             boolean localFileSystem)
                      throws IOException

Description copied from interface: MetaMasterClient

Writes a backup of the journal to the specified directory. The backup is written to the directory with a file name containing the date when the file was written.

Specified by:

backup in interface MetaMasterClient

Parameters:

targetDirectory - the directory in the UFS to write to, or null to use the default alluxio backup directory

localFileSystem - whether to write to the master's local filesystem instead of the UFS

Returns:

the server response

Throws:

IOException

getConfigReport

public ConfigCheckReport getConfigReport()
                                  throws IOException

Description copied from interface: MetaMasterClient

Gets the server-side configuration check report.

Specified by:

getConfigReport in interface MetaMasterClient

Returns:

configuration check report

Throws:

IOException

getConfiguration

public List<ConfigProperty> getConfiguration()
                                      throws IOException

Description copied from interface: MetaMasterClient

Gets the runtime configuration information.

Specified by:

getConfiguration in interface MetaMasterClient

Returns:

a list of configuration information

Throws:

IOException

getMasterInfo

public MasterInfo getMasterInfo(Set<MasterInfo.MasterInfoField> fields)
                         throws IOException

Specified by:

getMasterInfo in interface MetaMasterClient

Parameters:

fields - optional list of fields to query; if null all fields will be queried

Returns:

the requested master info

Throws:

IOException

getMetrics

public Map<String,MetricValue> getMetrics()
                                   throws AlluxioStatusException

Description copied from interface: MetaMasterClient

Gets a map of metrics property names and their values from metrics system.

Specified by:

getMetrics in interface MetaMasterClient

Returns:

a map of metrics information

Throws:

AlluxioStatusException