alluxio

Class AbstractMasterClient

java.lang.Object

alluxio.AbstractClient

alluxio.AbstractMasterClient

All Implemented Interfaces:

Client, Closeable, AutoCloseable

Direct Known Subclasses:

BlockMasterClient, FileSystemMasterClient, KeyValueMasterClient, LineageMasterClient, MetricsMasterClient, RetryHandlingBlockMasterClient, RetryHandlingFileSystemMasterClient, RetryHandlingMetaMasterClient, RetryHandlingMetaMasterMasterClient

@ThreadSafe
public abstract class AbstractMasterClient
extends AbstractClient

The base class for master clients.

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
AbstractMasterClient(MasterClientConfig conf) Creates a new master client base.
AbstractMasterClient(MasterClientConfig conf, InetSocketAddress address, java.util.function.Supplier<RetryPolicy> retryPolicySupplier) Creates a new master client base.

Method Summary

Modifier and Type	Method and Description
InetSocketAddress	getAddress()

Methods inherited from class alluxio.AbstractClient

afterConnect, afterDisconnect, beforeDisconnect, checkVersion, close, connect, disconnect, getClient, getServiceName, getServiceVersion, isConnected, retryRPC, retryRPC

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractMasterClient

public AbstractMasterClient(MasterClientConfig conf)

Creates a new master client base.

Parameters:

conf - master client configuration

AbstractMasterClient

public AbstractMasterClient(MasterClientConfig conf,
                            InetSocketAddress address,
                            java.util.function.Supplier<RetryPolicy> retryPolicySupplier)

Creates a new master client base.

Parameters:

conf - master client configuration

address - address to connect to

retryPolicySupplier - retry policy to use

Method Detail

getAddress

public InetSocketAddress getAddress()
                             throws UnavailableException

Specified by:

getAddress in interface Client

Overrides:

getAddress in class AbstractClient

Returns:

the InetSocketAddress of the remote,

Throws:

UnavailableException - if the primary address cannot be determined