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, Corneil du Plessis, Joe O'Brien

Field Summary

Fields

Modifier and Type	Field and Description
protected org.springframework.cloud.dataflow.audit.service.AuditRecordService	auditRecordService
protected DataflowJobExecutionDaoContainer	dataflowJobExecutionDaoContainer
protected DataflowTaskExecutionDaoContainer	dataflowTaskExecutionDaoContainer
protected DataflowTaskExecutionMetadataDaoContainer	dataflowTaskExecutionMetadataDaoContainer

Constructor Summary

Constructors

Constructor and Description

DefaultTaskDeleteService(org.springframework.cloud.dataflow.aggregate.task.AggregateTaskExplorer taskExplorer, LauncherRepository launcherRepository, TaskDefinitionRepository taskDefinitionRepository, TaskDeploymentRepository taskDeploymentRepository, org.springframework.cloud.dataflow.audit.service.AuditRecordService auditRecordService, DataflowTaskExecutionDaoContainer dataflowTaskExecutionDaoContainer, DataflowJobExecutionDaoContainer dataflowJobExecutionDaoContainer, DataflowTaskExecutionMetadataDaoContainer dataflowTaskExecutionMetadataDaoContainer, SchedulerService schedulerService, org.springframework.cloud.dataflow.schema.service.SchemaService schemaService, TaskConfigurationProperties taskConfigurationProperties, DataSource dataSource)

Method Summary

Modifier and Type	Method and Description
void	cleanupExecution(long id, String schemaTarget) Cleanup the resources that resulted from running the task with the given execution id.
void	cleanupExecutions(Set<TaskExecutionControllerDeleteAction> actionsAsSet, Set<Long> ids, String schemaTarget) Cleanup the resources that resulted from running the task with the given execution ids and actions.
void	cleanupExecutions(Set<TaskExecutionControllerDeleteAction> actionsAsSet, String taskName, boolean completed) Clean up the resources that resulted from running the task with the given name.
void	cleanupExecutions(Set<TaskExecutionControllerDeleteAction> actionsAsSet, String taskName, boolean completed, Integer days) Clean up the resources that resulted from running the task with the given name.
void	deleteAll() Destroy all task definitions.
void	deleteTaskDefinition(String name) Destroy the task definition.
void	deleteTaskDefinition(String name, boolean cleanup) Destroy the task definition.
void	deleteTaskExecutions(Set<Long> taskExecutionIds, String schemaTarget) Delete one or more Task executions.
void	deleteTaskExecutions(String taskName, boolean onlyCompleted) Delete task executions by name and execution state.

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

dataflowTaskExecutionDaoContainer

protected final DataflowTaskExecutionDaoContainer dataflowTaskExecutionDaoContainer

dataflowJobExecutionDaoContainer

protected final DataflowJobExecutionDaoContainer dataflowJobExecutionDaoContainer

dataflowTaskExecutionMetadataDaoContainer

protected final DataflowTaskExecutionMetadataDaoContainer dataflowTaskExecutionMetadataDaoContainer

Constructor Detail

DefaultTaskDeleteService

public DefaultTaskDeleteService(org.springframework.cloud.dataflow.aggregate.task.AggregateTaskExplorer taskExplorer,
                                LauncherRepository launcherRepository,
                                TaskDefinitionRepository taskDefinitionRepository,
                                TaskDeploymentRepository taskDeploymentRepository,
                                org.springframework.cloud.dataflow.audit.service.AuditRecordService auditRecordService,
                                DataflowTaskExecutionDaoContainer dataflowTaskExecutionDaoContainer,
                                DataflowJobExecutionDaoContainer dataflowJobExecutionDaoContainer,
                                DataflowTaskExecutionMetadataDaoContainer dataflowTaskExecutionMetadataDaoContainer,
                                SchedulerService schedulerService,
                                org.springframework.cloud.dataflow.schema.service.SchemaService schemaService,
                                TaskConfigurationProperties taskConfigurationProperties,
                                DataSource dataSource)

Method Detail

cleanupExecution

@Transactional
public void cleanupExecution(long id,
                                            String schemaTarget)

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

@Transactional
public void cleanupExecutions(Set<TaskExecutionControllerDeleteAction> actionsAsSet,
                                             String taskName,
                                             boolean completed)

Description copied from interface: TaskDeleteService

Clean up the resources that resulted from running the task with the given name.

Specified by:

cleanupExecutions in interface TaskDeleteService

Parameters:

actionsAsSet - the actions to perform

taskName - the task name

completed - whether to include only completed tasks

cleanupExecutions

@Transactional
public void cleanupExecutions(Set<TaskExecutionControllerDeleteAction> actionsAsSet,
                                             String taskName,
                                             boolean completed,
                                             Integer days)

Description copied from interface: TaskDeleteService

Clean up the resources that resulted from running the task with the given name.

Specified by:

cleanupExecutions in interface TaskDeleteService

Parameters:

actionsAsSet - the actions to perform

taskName - the task name

completed - whether to include only completed tasks (ignored when includeTasksEndedMinDaysAgo is specified)

days - only include tasks that have ended at least this many days ago

cleanupExecutions

@Transactional
public void cleanupExecutions(Set<TaskExecutionControllerDeleteAction> actionsAsSet,
                                             Set<Long> ids,
                                             String schemaTarget)

Description copied from interface: TaskDeleteService

Cleanup the resources that resulted from running the task with the given execution ids and actions.

Specified by:

cleanupExecutions in interface TaskDeleteService

Parameters:

actionsAsSet - the actions

ids - the id's

deleteTaskExecutions

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

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.

deleteTaskExecutions

public void deleteTaskExecutions(String taskName,
                                 boolean onlyCompleted)

Description copied from interface: TaskDeleteService

Delete task executions by name and execution state.

Specified by:

deleteTaskExecutions in interface TaskDeleteService

Parameters:

taskName - the name of the task executions

onlyCompleted - indicator to delete only completed tasks

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.

deleteTaskDefinition

public void deleteTaskDefinition(String name,
                                 boolean cleanup)

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. If the cleanup flag is set to true, delete all the task executions associated with the task definition.

Specified by:

deleteTaskDefinition in interface TaskDeleteService

Parameters:

name - The name of the task.

cleanup - the flag to indicate the cleanup of the task executions for the task definition.

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