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="/batch/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

Constructor Summary

Constructors

Constructor and Description
BatchJobExecutionsController()

Method Summary

Methods

Modifier and Type	Method and Description
JobExecutionInfoResource	getJobExecutionInfo(long executionId)
java.util.Collection<JobExecutionInfoResource>	list(int startJobExecution, int pageSize) 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)
@ResponseStatus(value=OK)
public java.util.Collection<JobExecutionInfoResource> list(@RequestParam(defaultValue="0")
                                                                                int startJobExecution,
                                                                                @RequestParam(defaultValue="20")
                                                                                int pageSize)

List all job executions in a given range.

Parameters:

startJobExecution - index of the first job execution to get

pageSize - how many executions to return

Returns:

Collection of JobExecutionInfoResource

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.