alluxio.client.meta

Class RetryHandlingMetaMasterClient

java.lang.Object

alluxio.AbstractClient

alluxio.AbstractMasterClient

alluxio.client.meta.RetryHandlingMetaMasterClient

All Implemented Interfaces:

alluxio.Client, MetaMasterClient, Closeable, AutoCloseable

@ThreadSafe
public class RetryHandlingMetaMasterClient
extends alluxio.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

alluxio.AbstractClient.RpcCallable<V>

Field Summary

Fields inherited from class alluxio.AbstractClient

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected void	afterConnect()
alluxio.wire.BackupResponse	backup(alluxio.grpc.BackupPOptions options) Writes a backup of the journal to the specified directory.
String	checkpoint() Creates a checkpoint in the primary master journal system.
alluxio.wire.ConfigCheckReport	getConfigReport() Gets the server-side configuration check report.
alluxio.grpc.MasterInfo	getMasterInfo(Set<alluxio.grpc.MasterInfoField> fields)
Map<String,alluxio.grpc.MetricValue>	getMetrics() Gets a map of metrics property names and their values from metrics system.
protected alluxio.grpc.ServiceType	getRemoteServiceType()
protected String	getServiceName()
protected long	getServiceVersion()

Methods inherited from class alluxio.AbstractMasterClient

getAddress

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(alluxio.master.MasterClientContext conf)

Creates a new meta master client.

Parameters:

conf - master client configuration

Method Detail

getRemoteServiceType

protected alluxio.grpc.ServiceType getRemoteServiceType()

Specified by:

getRemoteServiceType in class alluxio.AbstractClient

getServiceName

protected String getServiceName()

Specified by:

getServiceName in class alluxio.AbstractClient

getServiceVersion

protected long getServiceVersion()

Specified by:

getServiceVersion in class alluxio.AbstractClient

afterConnect

protected void afterConnect()

Overrides:

afterConnect in class alluxio.AbstractClient

backup

public alluxio.wire.BackupResponse backup(alluxio.grpc.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 alluxio.wire.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 alluxio.grpc.MasterInfo getMasterInfo(Set<alluxio.grpc.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,alluxio.grpc.MetricValue> getMetrics()
                                                throws alluxio.exception.status.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:

alluxio.exception.status.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