public class DefaultTaskDeleteService extends Object implements TaskDeleteService
TaskDeleteService
interface. Provide service
methods for Task deletion.Modifier and Type | Field and Description |
---|---|
protected org.springframework.cloud.dataflow.audit.service.AuditRecordService |
auditRecordService |
protected DataflowJobExecutionDao |
dataflowJobExecutionDao |
protected DataflowTaskExecutionDao |
dataflowTaskExecutionDao |
protected DataflowTaskExecutionMetadataDao |
dataflowTaskExecutionMetadataDao |
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,
DataflowTaskExecutionMetadataDao dataflowTaskExecutionMetadataDao,
SchedulerService schedulerService,
TaskConfigurationProperties taskConfigurationProperties,
DataSource dataSource) |
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)
Cleanup the resources that resulted from running the task with the given execution
ids and actions.
|
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)
Delete one or more Task executions.
|
protected final org.springframework.cloud.dataflow.audit.service.AuditRecordService auditRecordService
protected final DataflowTaskExecutionDao dataflowTaskExecutionDao
protected final DataflowJobExecutionDao dataflowJobExecutionDao
protected final DataflowTaskExecutionMetadataDao dataflowTaskExecutionMetadataDao
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, DataflowTaskExecutionMetadataDao dataflowTaskExecutionMetadataDao, SchedulerService schedulerService, TaskConfigurationProperties taskConfigurationProperties, DataSource dataSource)
public void cleanupExecution(long id)
TaskDeleteService
cleanupExecution
in interface TaskDeleteService
id
- the execution idpublic void cleanupExecutions(Set<TaskExecutionControllerDeleteAction> actionsAsSet, Set<Long> ids)
TaskDeleteService
cleanupExecutions
in interface TaskDeleteService
actionsAsSet
- the actionsids
- the id's@Transactional public void deleteTaskExecutions(Set<Long> taskExecutionIds)
TaskDeleteService
deleteTaskExecutions
in interface TaskDeleteService
taskExecutionIds
- Collection of task execution ids to delete. Must contain at least 1 id.public void deleteTaskDefinition(String name)
TaskDeleteService
deleteTaskDefinition
in interface TaskDeleteService
name
- The name of the task.public void deleteTaskDefinition(String name, boolean cleanup)
TaskDeleteService
deleteTaskDefinition
in interface TaskDeleteService
name
- The name of the task.cleanup
- the flag to indicate the cleanup of the task executions for the task definition.public void deleteAll()
TaskDeleteService
deleteAll
in interface TaskDeleteService
Copyright © 2022 Pivotal Software, Inc.. All rights reserved.