public class JobService extends BaseService
| Constructor and Description |
|---|
JobService(String clusterName,
String workflowId)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
javax.ws.rs.core.Response |
getJob(javax.ws.rs.core.HttpHeaders headers,
javax.ws.rs.core.UriInfo ui,
String jobId)
Handles: GET /workflows/{workflowId}/jobs/{jobId} Get a specific job.
|
javax.ws.rs.core.Response |
getJobs(javax.ws.rs.core.HttpHeaders headers,
javax.ws.rs.core.UriInfo ui)
Handles: GET /workflows/{workflowId}/jobs Get all jobs.
|
TaskAttemptService |
getTaskAttemptHandler(String jobId)
Gets the task attempts sub-resource.
|
getBodyParser, getResultSerializer, handleRequestpublic javax.ws.rs.core.Response getJob(@Context
javax.ws.rs.core.HttpHeaders headers,
@Context
javax.ws.rs.core.UriInfo ui,
String jobId)
headers - http headersui - uri infojobId - job idpublic javax.ws.rs.core.Response getJobs(@Context
javax.ws.rs.core.HttpHeaders headers,
@Context
javax.ws.rs.core.UriInfo ui)
headers - http headersui - uri infopublic TaskAttemptService getTaskAttemptHandler(String jobId)
Copyright © 2016. All rights reserved.