alluxio.client.job

Class RetryHandlingJobMasterClient

java.lang.Object

alluxio.AbstractClient

alluxio.AbstractMasterClient

alluxio.client.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 clients.

Nested Class Summary

Nested classes/interfaces inherited from class alluxio.AbstractClient

AbstractClient.RpcCallable<V>

Nested classes/interfaces inherited from interface alluxio.client.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.
void	cancel(long jobId) Cancels the given job.
JobServiceSummary	getJobServiceSummary() Gets the job service summary.
protected ServiceType	getRemoteServiceType()
protected String	getServiceName()
protected long	getServiceVersion()
JobInfo	getStatus(long jobId) Gets the status of the given job.
List<Long>	list()
long	run(JobConfig jobConfig) Starts a job based on the given configuration.

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 - 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()
                     throws IOException

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

Throws:

IOException

cancel

public void cancel(long jobId)
            throws IOException

Description copied from interface: JobMasterClient

Cancels the given job.

Specified by:

cancel in interface JobMasterClient

Parameters:

jobId - the job id

Throws:

IOException

getStatus

public JobInfo getStatus(long jobId)
                  throws IOException

Description copied from interface: JobMasterClient

Gets the status of the given job.

Specified by:

getStatus in interface JobMasterClient

Parameters:

jobId - the job id

Returns:

the job information

Throws:

IOException

getJobServiceSummary

public JobServiceSummary getJobServiceSummary()
                                       throws IOException

Description copied from interface: JobMasterClient

Gets the job service summary.

Specified by:

getJobServiceSummary in interface JobMasterClient

Returns:

the job service summary

Throws:

IOException

list

public List<Long> list()
                throws IOException

Specified by:

list in interface JobMasterClient

Returns:

the list of ids of all jobs

Throws:

IOException

run

public long run(JobConfig jobConfig)
         throws IOException

Description copied from interface: JobMasterClient

Starts a job based on the given configuration.

Specified by:

run in interface JobMasterClient

Parameters:

jobConfig - the job configuration

Returns:

the job id

Throws:

IOException