org.springframework.xd.dirt.rest

Class BatchStepExecutionsController

java.lang.Object

org.springframework.xd.dirt.rest.AbstractBatchJobsController

org.springframework.xd.dirt.rest.BatchStepExecutionsController

@RestController
@RequestMapping(value="/jobs/executions/{jobExecutionId}/steps")
@ExposesResourceFor(value=StepExecutionInfoResource.class)
public class BatchStepExecutionsController
extends AbstractBatchJobsController

Controller for returning Batch StepExecutions.

Author:

Gunnar Hillert, Dave Syer, Ilayaperumal Gopinathan

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
BatchStepExecutionsController()

Method Summary

Methods

Modifier and Type	Method and Description
StepExecutionInfoResource	details(long jobExecutionId, long stepExecutionId) Inspect the StepExecution with the provided Step Execution Id
java.util.Collection<StepExecutionInfoResource>	list(long jobExecutionId) List all step executions.
StepExecutionProgressInfoResource	progress(long jobExecutionId, long stepExecutionId) Get the step execution progress for the given jobExecutions step.

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

BatchStepExecutionsController

public BatchStepExecutionsController()

Method Detail

list

@RequestMapping(value="",
                method=GET,
                produces="application/json")
@ResponseStatus(value=OK)
public java.util.Collection<StepExecutionInfoResource> list(@PathVariable(value="jobExecutionId")
                                                                                 long jobExecutionId)

List all step executions.

Parameters:

jobExecutionId - Id of the JobExecution, must not be null

Returns:

Collection of StepExecutionInfoResource for the given jobExecutionId

Throws:

NoSuchJobExecutionException - Thrown if the respective JobExecution does not exist

details

@RequestMapping(value="/{stepExecutionId}",
                method=GET)
@ResponseStatus(value=OK)
public StepExecutionInfoResource details(@PathVariable
                                                              long jobExecutionId,
                                                              @PathVariable
                                                              long stepExecutionId)

Inspect the StepExecution with the provided Step Execution Id

Parameters:

jobExecutionId - Id of the JobExecution, must not be null

stepExecutionId - Id of the StepExecution, must not be null

Returns:

StepExecutionInfoResource that has the details on the given StepExecution.

Throws:

NoSuchJobExecutionException - Thrown if the respective JobExecution does not exist

NoSuchStepExecutionException - Thrown if the respective StepExecution does not exist

progress

@RequestMapping(value="/{stepExecutionId}/progress",
                method=GET)
@ResponseStatus(value=OK)
public StepExecutionProgressInfoResource progress(@PathVariable
                                                                       long jobExecutionId,
                                                                       @PathVariable
                                                                       long stepExecutionId)

Get the step execution progress for the given jobExecutions step.

Parameters:

jobExecutionId - Id of the JobExecution, must not be null

stepExecutionId - Id of the StepExecution, must not be null

Returns:

StepExecutionInfoResource that has the progress info on the given StepExecution.

Throws:

NoSuchJobExecutionException - Thrown if the respective JobExecution does not exist

NoSuchStepExecutionException - Thrown if the respective StepExecution does not exist