public class JdbcDataflowTaskExecutionDao extends Object implements DataflowTaskExecutionDao
JdbcTaskExecutionDao
but contains Spring Cloud Data Flow specific operations. This functionality might
be migrated to Spring Cloud Task itself eventually.Constructor and Description |
---|
JdbcDataflowTaskExecutionDao(DataSource dataSource,
org.springframework.cloud.task.configuration.TaskProperties taskProperties) |
Modifier and Type | Method and Description |
---|---|
int |
deleteTaskExecutionParamsByTaskExecutionIds(Set<Long> taskExecutionIds)
Deletes 1 or more task execution parameter records.
|
int |
deleteTaskExecutionsByTaskExecutionIds(Set<Long> taskExecutionIds)
Deletes 1 or more task executions
|
int |
deleteTaskTaskBatchRelationshipsByTaskExecutionIds(Set<Long> taskExecutionIds)
Deletes 1 or more task batch relationship records that links batch executions
to task executions.
|
Set<Long> |
findChildTaskExecutionIds(Set<Long> taskExecutionIds)
Finds all the child tasks for the taskExecution that is provided.
|
public JdbcDataflowTaskExecutionDao(DataSource dataSource, org.springframework.cloud.task.configuration.TaskProperties taskProperties)
dataSource
- used by the dao to execute queries and updates the tables.taskProperties
- the TaskProperties
to use for this dao.public int deleteTaskExecutionsByTaskExecutionIds(Set<Long> taskExecutionIds)
DataflowTaskExecutionDao
deleteTaskExecutionsByTaskExecutionIds
in interface DataflowTaskExecutionDao
taskExecutionIds
- Must contain at least 1 taskExecutionIdpublic int deleteTaskExecutionParamsByTaskExecutionIds(Set<Long> taskExecutionIds)
DataflowTaskExecutionDao
deleteTaskExecutionParamsByTaskExecutionIds
in interface DataflowTaskExecutionDao
taskExecutionIds
- Must contain at least 1 taskExecutionIdpublic int deleteTaskTaskBatchRelationshipsByTaskExecutionIds(Set<Long> taskExecutionIds)
DataflowTaskExecutionDao
deleteTaskTaskBatchRelationshipsByTaskExecutionIds
in interface DataflowTaskExecutionDao
taskExecutionIds
- Must contain at least 1 taskExecutionIdpublic Set<Long> findChildTaskExecutionIds(Set<Long> taskExecutionIds)
DataflowTaskExecutionDao
findChildTaskExecutionIds
in interface DataflowTaskExecutionDao
taskExecutionIds
- The ids to theTaskExecution
s to be searchedTaskExecution
s that correspond to the TaskExecution
s passed.Copyright © 2020 Pivotal Software, Inc.. All rights reserved.