alluxio.worker.job

Class RetryHandlingJobMasterClient

java.lang.Object

alluxio.AbstractClient

alluxio.AbstractMasterClient

alluxio.worker.job.RetryHandlingJobMasterClient

All Implemented Interfaces:

Client, JobMasterClient, Closeable, AutoCloseable

@ThreadSafe
public final class RetryHandlingJobMasterClient
extends AbstractMasterClient
implements JobMasterClient

A wrapper for the gRPC client to interact with the job service master, used by job service workers.

Nested Class Summary

Nested classes/interfaces inherited from class alluxio.AbstractClient

AbstractClient.RpcCallable<V>

Nested classes/interfaces inherited from interface alluxio.worker.job.JobMasterClient

JobMasterClient.Factory

Field Summary

Fields inherited from class alluxio.AbstractClient

mAddress, mChannel, mClosed, mConfAddress, mConnected, mContext, mServiceVersion, mVersionService

Constructor Summary

Constructors

Constructor and Description
RetryHandlingJobMasterClient(JobMasterClientContext conf) Creates a new job master client.

Method Summary

Modifier and Type	Method and Description
protected void	afterConnect() This method is called after the connection is made to the remote.
protected ServiceType	getRemoteServiceType()
protected String	getServiceName()
protected long	getServiceVersion()
List<JobCommand>	heartbeat(JobWorkerHealth jobWorkerHealth, List<JobInfo> taskInfoList) Periodic heartbeats to update the tasks' status from a worker, and returns the commands.
long	registerWorker(WorkerNetAddress address) Returns a worker id for a workers net address.

Methods inherited from class alluxio.AbstractMasterClient

getAddress, getConfAddress

Methods inherited from class alluxio.AbstractClient

afterDisconnect, beforeConnect, beforeDisconnect, checkVersion, close, connect, disconnect, getRemoteServiceVersion, isClosed, isConnected, retryRPC, retryRPC

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.Client

connect, disconnect, getAddress, getConfAddress, isClosed, isConnected

Methods inherited from interface java.io.Closeable

close

Constructor Detail

RetryHandlingJobMasterClient

public RetryHandlingJobMasterClient(JobMasterClientContext conf)

Creates a new job master client.

Parameters:

conf - job master client configuration

Method Detail

getRemoteServiceType

protected ServiceType getRemoteServiceType()

Specified by:

getRemoteServiceType in class AbstractClient

Returns:

the 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

registerWorker

public long registerWorker(WorkerNetAddress address)
                    throws IOException

Description copied from interface: JobMasterClient

Returns a worker id for a workers net address.

Specified by:

registerWorker in interface JobMasterClient

Parameters:

address - the net address to get a worker id for

Returns:

a worker id

Throws:

IOException - if an I/O error occurs

heartbeat

public List<JobCommand> heartbeat(JobWorkerHealth jobWorkerHealth,
                                  List<JobInfo> taskInfoList)
                           throws IOException

Description copied from interface: JobMasterClient

Periodic heartbeats to update the tasks' status from a worker, and returns the commands.

Specified by:

heartbeat in interface JobMasterClient

Parameters:

jobWorkerHealth - the job worker info

taskInfoList - the list of the task information

Returns:

the commands issued to the worker

Throws:

IOException - if an I/O error occurs