org.springframework.cloud.dataflow.server.controller

Class TaskExecutionController

java.lang.Object

org.springframework.cloud.dataflow.server.controller.TaskExecutionController

@RestController
 @RequestMapping(value="/tasks/executions")
 @ExposesResourceFor(value=TaskExecutionResource.class)
public class TaskExecutionController
extends Object

Controller for operations on TaskExecution. This includes obtaining task execution information from the task explorer.

Author:

Glenn Renfro, Michael Minella, Ilayaperumal Gopinathan, Christian Tzolov, David Turanski, Gunnar Hillert, Corneil du Plessis

Constructor Summary

Constructors

Constructor and Description

TaskExecutionController(org.springframework.cloud.dataflow.aggregate.task.AggregateTaskExplorer explorer, org.springframework.cloud.dataflow.aggregate.task.AggregateExecutionSupport aggregateExecutionSupport, TaskExecutionService taskExecutionService, TaskDefinitionRepository taskDefinitionRepository, org.springframework.cloud.dataflow.aggregate.task.TaskDefinitionReader taskDefinitionReader, TaskExecutionInfoService taskExecutionInfoService, TaskDeleteService taskDeleteService, TaskJobService taskJobService) Creates a TaskExecutionController that retrieves Task Execution information from a the TaskExplorer

Method Summary

Modifier and Type	Method and Description
void	cleanup(Set<Long> ids, TaskExecutionControllerDeleteAction[] actions, String schemaTarget) Cleanup resources associated with one or more task executions, specified by id(s).
void	cleanupAll(TaskExecutionControllerDeleteAction[] actions, boolean completed, String taskName, Integer days) Cleanup resources associated with one or more task executions.
Collection<CurrentTaskExecutionsResource>	getCurrentTaskExecutionsInfo()
long	launch(String taskName, String properties, String arguments) Request the launching of an existing task definition.
LaunchResponseResource	launchBoot3(String taskName, String properties, String arguments)
org.springframework.hateoas.PagedModel<TaskExecutionResource>	list(org.springframework.data.domain.Pageable pageable, org.springframework.data.web.PagedResourcesAssembler<TaskJobExecutionRel> assembler) Return a page-able list of TaskExecutionResource defined tasks.
org.springframework.hateoas.PagedModel<TaskExecutionResource>	retrieveTasksByName(String taskName, org.springframework.data.domain.Pageable pageable, org.springframework.data.web.PagedResourcesAssembler<TaskJobExecutionRel> assembler) Retrieve all task executions with the task name specified
void	stop(Set<Long> ids, String platform, String schemaTarget) Stop a set of task executions.
TaskExecutionResource	view(Long id, String schemaTarget) View the details of a single task execution, specified by id.
TaskExecutionResource	viewByExternal(String externalExecutionId, String platform)

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskExecutionController

public TaskExecutionController(org.springframework.cloud.dataflow.aggregate.task.AggregateTaskExplorer explorer,
                               org.springframework.cloud.dataflow.aggregate.task.AggregateExecutionSupport aggregateExecutionSupport,
                               TaskExecutionService taskExecutionService,
                               TaskDefinitionRepository taskDefinitionRepository,
                               org.springframework.cloud.dataflow.aggregate.task.TaskDefinitionReader taskDefinitionReader,
                               TaskExecutionInfoService taskExecutionInfoService,
                               TaskDeleteService taskDeleteService,
                               TaskJobService taskJobService)

Creates a TaskExecutionController that retrieves Task Execution information from a the TaskExplorer

Parameters:

explorer - the explorer this controller will use for retrieving task execution information.

aggregateExecutionSupport - provides schemaTarget for a task by name.

taskExecutionService - used to launch tasks

taskDefinitionRepository - the task definition repository

taskDefinitionReader - uses task definition repository to provide Task Definition to aggregateExecutionSupport

taskExecutionInfoService - the task execution information service

taskDeleteService - the task deletion service

taskJobService - the task job service

Method Detail

list

@RequestMapping(value="",
                method=GET)
 @ResponseStatus(value=OK)
public org.springframework.hateoas.PagedModel<TaskExecutionResource> list(org.springframework.data.domain.Pageable pageable,
                                                                                                                                                           org.springframework.data.web.PagedResourcesAssembler<TaskJobExecutionRel> assembler)

Return a page-able list of TaskExecutionResource defined tasks.

Parameters:

pageable - page-able collection of TaskExecutions.

assembler - for the TaskExecutions

Returns:

a list of task executions

retrieveTasksByName

@RequestMapping(value="",
                method=GET,
                params="name")
 @ResponseStatus(value=OK)
public org.springframework.hateoas.PagedModel<TaskExecutionResource> retrieveTasksByName(@RequestParam(value="name")
                                                                                                                                                                                                         String taskName,
                                                                                                                                                                                                         org.springframework.data.domain.Pageable pageable,
                                                                                                                                                                                                         org.springframework.data.web.PagedResourcesAssembler<TaskJobExecutionRel> assembler)

Retrieve all task executions with the task name specified

Parameters:

taskName - name of the task

pageable - page-able collection of TaskExecutions.

assembler - for the TaskExecutions

Returns:

the paged list of task executions

launch

@RequestMapping(value="",
                method=POST,
                params="name")
 @ResponseStatus(value=CREATED)
public long launch(@RequestParam(value="name")
                                                                                                                                         String taskName,
                                                                                                                                         @RequestParam(required=false)
                                                                                                                                         String properties,
                                                                                                                                         @RequestParam(required=false)
                                                                                                                                         String arguments)

Request the launching of an existing task definition. The task definition will be created from a registered task application if `spring.cloud.dataflow.task.auto-create-task-definitions` is true. The name must be included in the path.

Parameters:

taskName - the name of the task to be executed (required)

properties - the runtime properties for the task, as a comma-delimited list of key=value pairs

arguments - the runtime commandline arguments

Returns:

the taskExecutionId for the executed task

launchBoot3

@RequestMapping(value="/launch",
                method=POST,
                params="name")
 @ResponseStatus(value=CREATED)
public LaunchResponseResource launchBoot3(@RequestParam(value="name")
                                                                                                                                                                       String taskName,
                                                                                                                                                                       @RequestParam(required=false)
                                                                                                                                                                       String properties,
                                                                                                                                                                       @RequestParam(required=false)
                                                                                                                                                                       String arguments)

view

@RequestMapping(value="/{id}",
                method=GET)
 @ResponseStatus(value=OK)
public TaskExecutionResource view(@PathVariable(name="id")
                                                                                                                        Long id,
                                                                                                                        @RequestParam(name="schemaTarget",required=false)
                                                                                                                        String schemaTarget)

View the details of a single task execution, specified by id.

Parameters:

id - the id of the requested TaskExecution

Returns:

the TaskExecution

viewByExternal

@RequestMapping(value="/external/{externalExecutionId}",
                method=GET)
 @ResponseStatus(value=OK)
public TaskExecutionResource viewByExternal(@PathVariable(name="externalExecutionId")
                                                                                                                                                            String externalExecutionId,
                                                                                                                                                            @RequestParam(name="platform",required=false)
                                                                                                                                                            String platform)

getCurrentTaskExecutionsInfo

@RequestMapping(value="/current",
                method=GET)
 @ResponseStatus(value=OK)
public Collection<CurrentTaskExecutionsResource> getCurrentTaskExecutionsInfo()

cleanup

@RequestMapping(value="/{id}",
                method=DELETE)
 @ResponseStatus(value=OK)
public void cleanup(@PathVariable(value="id")
                                                                                                             Set<Long> ids,
                                                                                                             @RequestParam(defaultValue="CLEANUP",name="action")
                                                                                                             TaskExecutionControllerDeleteAction[] actions,
                                                                                                             @RequestParam(name="schemaTarget",required=false)
                                                                                                             String schemaTarget)

Cleanup resources associated with one or more task executions, specified by id(s). The optional actions parameter can be used to not only clean up task execution resources, but can also trigger the deletion of task execution and job data in the persistence store.

Parameters:

ids - The id of the TaskExecutions to clean up

actions - Defaults to "CLEANUP" if not specified

cleanupAll

@RequestMapping(method=DELETE)
 @ResponseStatus(value=OK)
 @Async(value="dataflowAsyncExecutor")
public void cleanupAll(@RequestParam(defaultValue="CLEANUP",name="action")
                                                                                                                        TaskExecutionControllerDeleteAction[] actions,
                                                                                                                        @RequestParam(defaultValue="false",name="completed")
                                                                                                                        boolean completed,
                                                                                                                        @RequestParam(defaultValue="",name="name")
                                                                                                                        String taskName,
                                                                                                                        @RequestParam(name="days",required=false)
                                                                                                                        Integer days)

Cleanup resources associated with one or more task executions. The optional actions and completed parameters can be used to not only clean up task execution resources, but can also trigger the deletion of task execution and job data in the persistence store.

When the spring.cloud.dataflow.async.enabled property is set to true the cleanup will happen asynchronously.

Parameters:

actions - the actions to perform (default 'CLEANUP')

completed - whether to include only completed task executions (default false)

taskName - name of the task (default '')

days - only include tasks that have ended at least this many days ago (default null)

stop

@RequestMapping(value="/{id}",
                method=POST)
 @ResponseStatus(value=OK)
public void stop(@PathVariable(value="id")
                                                                                                        Set<Long> ids,
                                                                                                        @RequestParam(defaultValue="",name="platform")
                                                                                                        String platform,
                                                                                                        @RequestParam(name="schemaTarget",required=false)
                                                                                                        String schemaTarget)

Stop a set of task executions.

Parameters:

ids - the ids of the TaskExecutions to stop

platform - the platform name