@Singleton
@Path(value="/v1/jobs")
public class TasksResource
extends java.lang.Object
Constructor and Description |
---|
TasksResource(TaskResourceConfig config)
Initializes a TaskResource with
TaskProxy from the
TaskProxyFactory class specified in the configuration. |
Modifier and Type | Method and Description |
---|---|
javax.ws.rs.core.Response |
getTasks(java.lang.String jobName,
java.lang.String jobId)
Gets the list of
Task for the job instance specified by jobName and jobId. |
public TasksResource(TaskResourceConfig config)
TaskProxy
from the
TaskProxyFactory
class specified in the configuration.config
- the configuration containing the TaskProxyFactory
class.@GET @Path(value="/{jobName}/{jobId}/tasks") @Produces(value="application/json") public javax.ws.rs.core.Response getTasks(@PathParam(value="jobName") java.lang.String jobName, @PathParam(value="jobId") java.lang.String jobId)
Task
for the job instance specified by jobName and jobId.jobName
- the name of the job as configured in JobConfig.JOB_NAME
jobId
- the id of the job as configured in JobConfig.JOB_ID
.Response.Status.OK
Response
contains a list of Task
, where each task belongs to
the samza job. Response.Status.BAD_REQUEST
is returned for invalid
job instances.