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, handleRequest
public 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 © 2015. All rights reserved.