org.springframework.xd.dirt.rest

Class BatchJobExecutionsController

java.lang.Object

org.springframework.xd.dirt.rest.AbstractBatchJobsController

org.springframework.xd.dirt.rest.BatchJobExecutionsController

@RestController
@RequestMapping(value="/jobs/executions")
@ExposesResourceFor(value=JobExecutionInfoResource.class)
public class BatchJobExecutionsController
extends AbstractBatchJobsController

Controller for batch job executions.

Author:

Dave Syer, Ilayaperumal Gopinathan, Gunnar Hillert

Field Summary

Fields inherited from class org.springframework.xd.dirt.rest.AbstractBatchJobsController

jobExecutionInfoResourceAssembler, jobInfoResourceAssembler, jobInstanceInfoResourceAssembler, jobService, progressInfoResourceAssembler, stepExecutionInfoResourceAssembler, timeZone, xdJobDefinitionRepository, xdJobrepository

Constructor Summary

Constructors

Constructor and Description
BatchJobExecutionsController()

Method Summary

Methods

Modifier and Type	Method and Description
java.util.Collection<JobExecutionInfoResource>	executionsForJob(java.lang.String jobName, int startJobExecution, int pageSize) Return a paged collection of job executions for a given job.
JobExecutionInfoResource	getJobExecutionInfo(long executionId)
void	launchJob(java.lang.String name, java.lang.String jobParameters) Send the request to launch Job.
org.springframework.hateoas.PagedResources<JobExecutionInfoResource>	list(org.springframework.data.domain.Pageable pageable) List all job executions in a given range.
void	restartJobExecution(long jobExecutionId) Restart the Job Execution with the given executionId.
void	stopAll() Stop all job executions.
void	stopJobExecution(long jobExecutionId) Stop Job Execution by the given executionId.

Methods inherited from class org.springframework.xd.dirt.rest.AbstractBatchJobsController

setTimeZone

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BatchJobExecutionsController

public BatchJobExecutionsController()

Method Detail

list

@RequestMapping(value="",
                method=GET,
                produces="application/json")
@ResponseStatus(value=OK)
public org.springframework.hateoas.PagedResources<JobExecutionInfoResource> list(org.springframework.data.domain.Pageable pageable)

List all job executions in a given range. If no pagination is provided, the default PageRequest(0, 20) is passed in. See PageableHandlerMethodArgumentResolver for details.

Parameters:

pageable - If not provided will default to page 0 and a page size of 20

Returns:

Collection of JobExecutionInfoResource

executionsForJob

@RequestMapping(value="",
                method=GET,
                params="jobname",
                produces="application/json")
@ResponseStatus(value=OK)
public java.util.Collection<JobExecutionInfoResource> executionsForJob(@RequestParam(value="jobname")
                                                                                            java.lang.String jobName,
                                                                                            @RequestParam(defaultValue="0")
                                                                                            int startJobExecution,
                                                                                            @RequestParam(defaultValue="20")
                                                                                            int pageSize)

Return a paged collection of job executions for a given job.

Parameters:

jobName - name of the job

startJobExecution - start index for the job execution list

pageSize - page size for the list

Returns:

collection of JobExecutionInfo

launchJob

@RequestMapping(value="",
                method=POST,
                params="jobname")
@ResponseStatus(value=CREATED)
public void launchJob(@RequestParam(value="jobname")
                                           java.lang.String name,
                                           @RequestParam(required=false)
                                           java.lang.String jobParameters)

Send the request to launch Job. Job has to be deployed first.

Parameters:

name - the name of the job

jobParameters - the job parameters in JSON string

getJobExecutionInfo

@RequestMapping(value="/{executionId}",
                method=GET)
@ResponseStatus(value=OK)
public JobExecutionInfoResource getJobExecutionInfo(@PathVariable
                                                                         long executionId)

Parameters:

executionId - Id of the JobExecution

Returns:

JobExecutionInfo for the given job name

Throws:

NoSuchJobExecutionException - Thrown if the JobExecution does not exist

stopJobExecution

@RequestMapping(value="/{executionId}",
                method=PUT,
                params="stop=true")
@ResponseStatus(value=OK)
public void stopJobExecution(@PathVariable(value="executionId")
                                                  long jobExecutionId)

Stop Job Execution by the given executionId.

Parameters:

jobExecutionId - the executionId of the job execution to stop

restartJobExecution

@RequestMapping(value="/{executionId}",
                method=PUT,
                params="restart=true")
@ResponseStatus(value=OK)
public void restartJobExecution(@PathVariable(value="executionId")
                                                     long jobExecutionId)

Restart the Job Execution with the given executionId.

Parameters:

jobExecutionId - the executionId of the job execution to restart

stopAll

@RequestMapping(value="",
                method=PUT,
                params="stop=true")
@ResponseStatus(value=OK)
public void stopAll()

Stop all job executions.