@ThreadSafe public final class RetryHandlingJobMasterClient extends AbstractMasterClient implements JobMasterClient
AbstractClient.RpcCallable<V>
JobMasterClient.Factory
mAddress, mChannel, mClosed, mConfAddress, mConnected, mContext, mServiceVersion, mVersionService
Constructor and Description |
---|
RetryHandlingJobMasterClient(JobMasterClientContext conf)
Creates a new job master client.
|
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.
|
List<JobWorkerHealth> |
getAllWorkerHealth()
Gets all worker health.
|
JobServiceSummary |
getJobServiceSummary()
Gets the job service summary.
|
JobInfo |
getJobStatus(long id)
Gets the status of the given job id.
|
protected ServiceType |
getRemoteServiceType() |
protected String |
getServiceName() |
protected long |
getServiceVersion() |
List<Long> |
list() |
List<JobInfo> |
listDetailed() |
long |
run(JobConfig jobConfig)
Starts a plan based on the given configuration.
|
getAddress, getConfAddress
afterDisconnect, beforeConnect, beforeDisconnect, checkVersion, close, connect, disconnect, getRemoteServiceVersion, isClosed, isConnected, retryRPC, retryRPC
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
connect, disconnect, getAddress, getConfAddress, isClosed, isConnected
public RetryHandlingJobMasterClient(JobMasterClientContext conf)
conf
- master client configurationprotected ServiceType getRemoteServiceType()
getRemoteServiceType
in class AbstractClient
protected String getServiceName()
getServiceName
in class AbstractClient
protected long getServiceVersion()
getServiceVersion
in class AbstractClient
protected void afterConnect() throws IOException
AbstractClient
afterConnect
in class AbstractClient
IOException
public void cancel(long jobId) throws IOException
JobMasterClient
cancel
in interface JobMasterClient
jobId
- the job idIOException
public JobInfo getJobStatus(long id) throws IOException
JobMasterClient
getJobStatus
in interface JobMasterClient
id
- the job idIOException
public JobServiceSummary getJobServiceSummary() throws IOException
JobMasterClient
getJobServiceSummary
in interface JobMasterClient
IOException
public List<Long> list() throws IOException
list
in interface JobMasterClient
IOException
public List<JobInfo> listDetailed() throws IOException
listDetailed
in interface JobMasterClient
IOException
public long run(JobConfig jobConfig) throws IOException
JobMasterClient
run
in interface JobMasterClient
jobConfig
- the job configurationIOException
public List<JobWorkerHealth> getAllWorkerHealth() throws IOException
JobMasterClient
getAllWorkerHealth
in interface JobMasterClient
IOException
Copyright © 2023. All Rights Reserved.