public interface JobMasterClient extends Client
Modifier and Type | Interface and Description |
---|---|
static class |
JobMasterClient.Factory
Factory for
JobMasterClient . |
Modifier and Type | Method and Description |
---|---|
void |
cancel(long id)
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.
|
JobInfo |
getJobStatusDetailed(long id)
Gets detailed status of the given job id.
|
List<Long> |
list() |
List<JobInfo> |
listDetailed() |
long |
run(JobConfig jobConfig)
Starts a plan based on the given configuration.
|
connect, disconnect, getAddress, getConfAddress, isClosed, isConnected
void cancel(long id) throws IOException
id
- the job idIOException
JobInfo getJobStatus(long id) throws IOException
id
- the job idIOException
JobInfo getJobStatusDetailed(long id) throws IOException
id
- the job idIOException
JobServiceSummary getJobServiceSummary() throws IOException
IOException
List<Long> list() throws IOException
IOException
List<JobInfo> listDetailed() throws IOException
IOException
long run(JobConfig jobConfig) throws IOException
jobConfig
- the job configurationIOException
List<JobWorkerHealth> getAllWorkerHealth() throws IOException
IOException
Copyright © 2023. All Rights Reserved.