org.springframework.cloud.dataflow.server.service.impl

Class DefaultTaskDeleteService

java.lang.Object

org.springframework.cloud.dataflow.server.service.impl.DefaultTaskDeleteService

All Implemented Interfaces:

TaskDeleteService

public class DefaultTaskDeleteService
extends Object
implements TaskDeleteService

Default implementation of the TaskDeleteService interface. Provide service methods for Task deletion.

Author:

Michael Minella, Marius Bogoevici, Glenn Renfro, Mark Fisher, Janne Valkealahti, Gunnar Hillert, Thomas Risberg, Ilayaperumal Gopinathan, Michael Wirth, David Turanski, Daniel Serleg

Field Summary

Fields

Modifier and Type	Field and Description
protected org.springframework.cloud.dataflow.audit.service.AuditRecordService	auditRecordService
protected DataflowJobExecutionDao	dataflowJobExecutionDao
protected DataflowTaskExecutionDao	dataflowTaskExecutionDao

Constructor Summary

Constructors

Constructor and Description

DefaultTaskDeleteService(org.springframework.cloud.task.repository.TaskExplorer taskExplorer, LauncherRepository launcherRepository, TaskDefinitionRepository taskDefinitionRepository, TaskDeploymentRepository taskDeploymentRepository, org.springframework.cloud.dataflow.audit.service.AuditRecordService auditRecordService, DataflowTaskExecutionDao dataflowTaskExecutionDao, DataflowJobExecutionDao dataflowJobExecutionDao)

Method Summary

Modifier and Type	Method and Description
void	cleanupExecution(long id) Cleanup the resources that resulted from running the task with the given execution id.
void	cleanupExecutions(Set<TaskExecutionControllerDeleteAction> actionsAsSet, Set<Long> ids)
void	deleteAll() Destroy all task definitions.
void	deleteTaskDefinition(String name) Destroy the task definition.
void	deleteTaskExecutions(Set<Long> taskExecutionIds) Delete one or more Task executions.

Methods inherited from class java.lang.Object

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

Field Detail

auditRecordService

protected final org.springframework.cloud.dataflow.audit.service.AuditRecordService auditRecordService

dataflowTaskExecutionDao

protected final DataflowTaskExecutionDao dataflowTaskExecutionDao

dataflowJobExecutionDao

protected final DataflowJobExecutionDao dataflowJobExecutionDao

Constructor Detail

DefaultTaskDeleteService

public DefaultTaskDeleteService(org.springframework.cloud.task.repository.TaskExplorer taskExplorer,
                                LauncherRepository launcherRepository,
                                TaskDefinitionRepository taskDefinitionRepository,
                                TaskDeploymentRepository taskDeploymentRepository,
                                org.springframework.cloud.dataflow.audit.service.AuditRecordService auditRecordService,
                                DataflowTaskExecutionDao dataflowTaskExecutionDao,
                                DataflowJobExecutionDao dataflowJobExecutionDao)

Method Detail

cleanupExecution

public void cleanupExecution(long id)

Description copied from interface: TaskDeleteService

Cleanup the resources that resulted from running the task with the given execution id.

Specified by:

cleanupExecution in interface TaskDeleteService

Parameters:

id - the execution id

cleanupExecutions

public void cleanupExecutions(Set<TaskExecutionControllerDeleteAction> actionsAsSet,
                              Set<Long> ids)

Specified by:

cleanupExecutions in interface TaskDeleteService

deleteTaskExecutions

@Transactional
public void deleteTaskExecutions(Set<Long> taskExecutionIds)

Description copied from interface: TaskDeleteService

Delete one or more Task executions.

Specified by:

deleteTaskExecutions in interface TaskDeleteService

Parameters:

taskExecutionIds - Collection of task execution ids to delete. Must contain at least 1 id.

deleteTaskDefinition

public void deleteTaskDefinition(String name)

Description copied from interface: TaskDeleteService

Destroy the task definition. If it is a Composed Task then the task definitions required for a ComposedTaskRunner task are also destroyed.

Specified by:

deleteTaskDefinition in interface TaskDeleteService

Parameters:

name - The name of the task.

deleteAll

public void deleteAll()

Description copied from interface: TaskDeleteService

Destroy all task definitions. If it is a Composed Task then the task definitions required for a ComposedTaskRunner tasks are also destroyed.

Specified by:

deleteAll in interface TaskDeleteService