alluxio.client.meta

Class RetryHandlingMetaMasterClient

java.lang.Object

alluxio.AbstractClient

alluxio.AbstractMasterClient

alluxio.client.meta.RetryHandlingMetaMasterClient

All Implemented Interfaces:

Client, MetaMasterClient, Closeable, AutoCloseable

@ThreadSafe
public class RetryHandlingMetaMasterClient
extends AbstractMasterClient
implements MetaMasterClient

A wrapper for the gRPC client to interact with the meta master.

Nested Class Summary

Nested classes/interfaces inherited from class alluxio.AbstractClient

AbstractClient.RpcCallable<V>

Field Summary

Fields inherited from class alluxio.AbstractClient

mAddress, mChannel, mClosed, mConfAddress, mConnected, mContext, mServiceVersion, mVersionService

Constructor Summary

Constructors

Constructor and Description
RetryHandlingMetaMasterClient(MasterClientContext 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(BackupPOptions options) Writes a backup of the journal to the specified directory.
String	checkpoint() Creates a checkpoint in the primary master journal system.
ConfigCheckReport	getConfigReport() Gets the server-side configuration check report.
MasterInfo	getMasterInfo(Set<MasterInfoField> fields)
Map<String,MetricValue>	getMetrics() Gets a map of metrics property names and their values from metrics system.
protected ServiceType	getRemoteServiceType()
protected String	getServiceName()
protected long	getServiceVersion()

Methods inherited from class alluxio.AbstractMasterClient

getAddress, getConfAddress

Methods inherited from class alluxio.AbstractClient

afterDisconnect, beforeConnect, beforeDisconnect, checkVersion, close, connect, disconnect, getRemoteServiceVersion, isClosed, 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(MasterClientContext conf)

Creates a new meta master client.

Parameters:

conf - master client configuration

Method Detail

getRemoteServiceType

protected ServiceType getRemoteServiceType()

Specified by:

getRemoteServiceType in class AbstractClient

Returns:

the type of remote service

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(BackupPOptions options)
                      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:

options - backup options

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

getMasterInfo

public MasterInfo getMasterInfo(Set<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

checkpoint

public String checkpoint()
                  throws IOException

Description copied from interface: MetaMasterClient

Creates a checkpoint in the primary master journal system.

Specified by:

checkpoint in interface MetaMasterClient

Returns:

the hostname of the master that did the checkpoint

Throws:

IOException