alluxio.master.meta

Class RetryHandlingJobMasterMasterClient

java.lang.Object

alluxio.AbstractClient

alluxio.AbstractMasterClient

alluxio.AbstractJobMasterClient

alluxio.master.meta.RetryHandlingJobMasterMasterClient

All Implemented Interfaces:

Client, Closeable, AutoCloseable

@ThreadSafe
public final class RetryHandlingJobMasterMasterClient
extends AbstractJobMasterClient

A wrapper for the gRPC client to interact with the primary job master, used by Alluxio standby job masters.

Nested Class Summary

Nested classes/interfaces inherited from class alluxio.AbstractClient

AbstractClient.RpcCallable<V>

Field Summary

Fields inherited from class alluxio.AbstractJobMasterClient

mConfAddress

Fields inherited from class alluxio.AbstractClient

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

Constructor Summary

Constructors

Constructor and Description
RetryHandlingJobMasterMasterClient(JobMasterClientContext conf) Creates a instance of RetryHandlingJobMasterMasterClient.

Method Summary

Modifier and Type	Method and Description
protected void	afterConnect() This method is called after the connection is made to the remote.
void	connect() Connects with the remote.
long	getId(Address address) Returns a master id for a master address.
protected ServiceType	getRemoteServiceType()
protected String	getServiceName()
protected long	getServiceVersion()
JobMasterMetaCommand	heartbeat(long masterId) Sends a heartbeat to the leader master.
void	register(long masterId) Registers with the leader master.

Methods inherited from class alluxio.AbstractJobMasterClient

getConfAddress

Methods inherited from class alluxio.AbstractMasterClient

afterDisconnect, beforeConnect, queryGrpcServerAddress

Methods inherited from class alluxio.AbstractClient

beforeDisconnect, checkVersion, close, connectWithRuntimeException, createChannel, disconnect, getRemoteHostName, getRemoteServiceVersion, getRemoteSockAddress, isClosed, isConnected, retryRPC, retryRPC

Methods inherited from class java.lang.Object

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

Constructor Detail

RetryHandlingJobMasterMasterClient

public RetryHandlingJobMasterMasterClient(JobMasterClientContext conf)

Creates a instance of RetryHandlingJobMasterMasterClient.

Parameters:

conf - master client configuration

Method Detail

connect

public void connect()
             throws AlluxioStatusException

Description copied from class: AbstractClient

Connects with the remote.

Specified by:

connect in interface Client

Overrides:

connect in class AbstractClient

Throws:

AlluxioStatusException

getRemoteServiceType

protected ServiceType getRemoteServiceType()

Specified by:

getRemoteServiceType in class AbstractClient

Returns:

the expected type of remote service

getServiceName

protected String getServiceName()

Specified by:

getServiceName in class AbstractClient

Returns:

a string representing the specific service

getServiceVersion

protected long getServiceVersion()

Specified by:

getServiceVersion in class AbstractClient

Returns:

the client service version

afterConnect

protected void afterConnect()

Description copied from class: AbstractClient

This method is called after the connection is made to the remote. Implementations should create internal state to finish the connection process.

Overrides:

afterConnect in class AbstractClient

getId

public long getId(Address address)
           throws IOException

Returns a master id for a master address.

Parameters:

address - the address to get a master id for

Returns:

a master id

Throws:

IOException

heartbeat

public JobMasterMetaCommand heartbeat(long masterId)
                               throws IOException

Sends a heartbeat to the leader master. Standby masters periodically execute this method so that the leader master knows they are still running.

Parameters:

masterId - the master id

Returns:

whether this master should re-register

Throws:

IOException

register

public void register(long masterId)
              throws IOException

Registers with the leader master.

Parameters:

masterId - the master id of the standby master registering

Throws:

IOException