alluxio

Class AbstractJobMasterClient

java.lang.Object

alluxio.AbstractClient

alluxio.AbstractMasterClient

alluxio.AbstractJobMasterClient

All Implemented Interfaces:

Client, Closeable, AutoCloseable

Direct Known Subclasses:

RetryHandlingJobMasterClient, RetryHandlingJobMasterClient, RetryHandlingJournalMasterClient

@ThreadSafe
public abstract class AbstractJobMasterClient
extends AbstractMasterClient

The base class for job master clients.

Nested Class Summary

Nested classes/interfaces inherited from class alluxio.AbstractClient

AbstractClient.RpcCallable<V>

Field Summary

Fields

Modifier and Type	Field and Description
protected InetSocketAddress	mConfAddress Address to load configuration, which may differ from mAddress.

Fields inherited from class alluxio.AbstractClient

mChannel, mClosed, mConnected, mContext, mServerAddress, mServiceVersion, mVersionService

Constructor Summary

Constructors

Constructor and Description
AbstractJobMasterClient(MasterClientContext clientConf) Creates a new master client base.
AbstractJobMasterClient(MasterClientContext clientConf, java.util.function.Supplier<RetryPolicy> retryPolicySupplier) Creates a new master client base.

Method Summary

Modifier and Type	Method and Description
InetSocketAddress	getConfAddress() By default, return the same underlying address as AbstractClient.getRemoteSockAddress().

Methods inherited from class alluxio.AbstractMasterClient

afterDisconnect, beforeConnect, queryGrpcServerAddress

Methods inherited from class alluxio.AbstractClient

afterConnect, beforeDisconnect, checkVersion, close, connect, connectWithRuntimeException, disconnect, getRemoteHostName, getRemoteServiceType, getRemoteServiceVersion, getRemoteSockAddress, getServiceName, getServiceVersion, isClosed, isConnected, retryRPC, retryRPC

Methods inherited from class java.lang.Object

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

Field Detail

mConfAddress

protected InetSocketAddress mConfAddress

Address to load configuration, which may differ from mAddress.

Constructor Detail

AbstractJobMasterClient

public AbstractJobMasterClient(MasterClientContext clientConf)

Creates a new master client base.

Parameters:

clientConf - master client configuration

AbstractJobMasterClient

public AbstractJobMasterClient(MasterClientContext clientConf,
                               java.util.function.Supplier<RetryPolicy> retryPolicySupplier)

Creates a new master client base.

Parameters:

clientConf - master client configuration

retryPolicySupplier - retry policy to use

Method Detail

getConfAddress

public InetSocketAddress getConfAddress()
                                 throws UnavailableException

Description copied from class: AbstractClient

By default, return the same underlying address as AbstractClient.getRemoteSockAddress(). Child classes should override this implementation if they intend to have different address to fetch configuration.

Specified by:

getConfAddress in interface Client

Overrides:

getConfAddress in class AbstractMasterClient

Returns:

the remote address of the configuration server

Throws:

UnavailableException - if address cannot be determined