alluxio.master

Class PollingMasterInquireClient

java.lang.Object

alluxio.master.PollingMasterInquireClient

All Implemented Interfaces:

MasterInquireClient

public class PollingMasterInquireClient
extends Object
implements MasterInquireClient

PollingMasterInquireClient finds the address of the primary master by polling a list of master addresses to see if their RPC servers are serving. This works because only primary masters serve RPCs.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PollingMasterInquireClient.MultiMasterConnectDetails Details used to connect to the leader Alluxio master when there are multiple potential leaders.

Nested classes/interfaces inherited from interface alluxio.master.MasterInquireClient

MasterInquireClient.ConnectDetails, MasterInquireClient.Factory

Constructor Summary

Constructors

Constructor and Description
PollingMasterInquireClient(List<InetSocketAddress> masterAddresses, AlluxioConfiguration alluxioConf, UserState userState, ServiceType serviceType)
PollingMasterInquireClient(List<InetSocketAddress> masterAddresses, java.util.function.Supplier<RetryPolicy> retryPolicySupplier, AlluxioConfiguration alluxioConf, ServiceType serviceType)
PollingMasterInquireClient(List<InetSocketAddress> masterAddresses, java.util.function.Supplier<RetryPolicy> retryPolicySupplier, AlluxioConfiguration alluxioConf, UserState userState, ServiceType serviceType)

Method Summary

Modifier and Type	Method and Description
MasterInquireClient.ConnectDetails	getConnectDetails() Returns canonical connect details representing how this client connects to the master.
List<InetSocketAddress>	getMasterRpcAddresses()
InetSocketAddress	getPrimaryRpcAddress()

Methods inherited from class java.lang.Object

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

Constructor Detail

PollingMasterInquireClient

public PollingMasterInquireClient(List<InetSocketAddress> masterAddresses,
                                  AlluxioConfiguration alluxioConf,
                                  UserState userState,
                                  ServiceType serviceType)

Parameters:

masterAddresses - the potential master addresses

alluxioConf - Alluxio configuration

userState - user state

serviceType - service type

PollingMasterInquireClient

public PollingMasterInquireClient(List<InetSocketAddress> masterAddresses,
                                  java.util.function.Supplier<RetryPolicy> retryPolicySupplier,
                                  AlluxioConfiguration alluxioConf,
                                  ServiceType serviceType)

Parameters:

masterAddresses - the potential master addresses

retryPolicySupplier - the retry policy supplier

alluxioConf - Alluxio configuration

serviceType - service type

PollingMasterInquireClient

public PollingMasterInquireClient(List<InetSocketAddress> masterAddresses,
                                  java.util.function.Supplier<RetryPolicy> retryPolicySupplier,
                                  AlluxioConfiguration alluxioConf,
                                  UserState userState,
                                  ServiceType serviceType)

Parameters:

masterAddresses - the potential master addresses

retryPolicySupplier - the retry policy supplier

alluxioConf - Alluxio configuration

userState - user state

serviceType - service type

Method Detail

getPrimaryRpcAddress

public InetSocketAddress getPrimaryRpcAddress()
                                       throws UnavailableException

Specified by:

getPrimaryRpcAddress in interface MasterInquireClient

Returns:

the rpc address of the primary master. The implementation should perform retries if appropriate

Throws:

UnavailableException - if the primary rpc address cannot be determined

getMasterRpcAddresses

public List<InetSocketAddress> getMasterRpcAddresses()

Specified by:

getMasterRpcAddresses in interface MasterInquireClient

Returns:

a list of all masters' RPC addresses

getConnectDetails

public MasterInquireClient.ConnectDetails getConnectDetails()

Description copied from interface: MasterInquireClient

Returns canonical connect details representing how this client connects to the master.

Specified by:

getConnectDetails in interface MasterInquireClient

Returns:

the connect details