alluxio.master.selectionpolicy

Class AbstractMasterSelectionPolicy

java.lang.Object

alluxio.master.selectionpolicy.AbstractMasterSelectionPolicy

All Implemented Interfaces:

MasterSelectionPolicy

Direct Known Subclasses:

SelectionPolicyAnyMaster, SelectionPolicyAnyStandbyMaster, SelectionPolicyPrimaryMaster, SelectionPolicySpecifiedMaster

public abstract class AbstractMasterSelectionPolicy
extends Object
implements MasterSelectionPolicy

Base class of master selection policy that determines which master node a client should connect to.

Nested Class Summary

Nested classes/interfaces inherited from interface alluxio.master.selectionpolicy.MasterSelectionPolicy

MasterSelectionPolicy.Factory, MasterSelectionPolicy.Type

Field Summary

Fields

Modifier and Type	Field and Description
protected InetSocketAddress	mPrimaryMasterAddress

Constructor Summary

Constructors

Constructor and Description
AbstractMasterSelectionPolicy()

Method Summary

Modifier and Type	Method and Description
abstract InetSocketAddress	getGrpcMasterAddress(MasterInquireClient masterInquireClient) Gets the master address the client makes gRPC request to.
InetSocketAddress	getPrimaryMasterAddressCached(MasterInquireClient masterInquireClient) Get and cache the primary master address.
void	resetPrimaryMasterAddressCache() Resets the cached primary master address.

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.master.selectionpolicy.MasterSelectionPolicy

getType

Field Detail

mPrimaryMasterAddress

@Nullable
protected volatile InetSocketAddress mPrimaryMasterAddress

Constructor Detail

AbstractMasterSelectionPolicy

public AbstractMasterSelectionPolicy()

Method Detail

getPrimaryMasterAddressCached

public InetSocketAddress getPrimaryMasterAddressCached(MasterInquireClient masterInquireClient)
                                                throws UnavailableException

Description copied from interface: MasterSelectionPolicy

Get and cache the primary master address.

Specified by:

getPrimaryMasterAddressCached in interface MasterSelectionPolicy

Parameters:

masterInquireClient - master inquire client

Returns:

the remote address of primary master gRPC server

Throws:

UnavailableException - if address cannot be determined

getGrpcMasterAddress

public abstract InetSocketAddress getGrpcMasterAddress(MasterInquireClient masterInquireClient)
                                                throws UnavailableException

Description copied from interface: MasterSelectionPolicy

Gets the master address the client makes gRPC request to.

Specified by:

getGrpcMasterAddress in interface MasterSelectionPolicy

Parameters:

masterInquireClient - master inquire client

Returns:

the remote address of master gRPC server

Throws:

UnavailableException - if address cannot be determined

resetPrimaryMasterAddressCache

public void resetPrimaryMasterAddressCache()

Description copied from interface: MasterSelectionPolicy

Resets the cached primary master address.

Specified by:

resetPrimaryMasterAddressCache in interface MasterSelectionPolicy