org.springframework.cloud.dataflow.server.repository

Interface DataflowTaskExecutionDao

All Known Implementing Classes:

JdbcDataflowTaskExecutionDao

public interface DataflowTaskExecutionDao

Repository to access TaskExecutions. Mirrors the TaskExecutionDao but contains Spring Cloud Data Flow specific operations. This functionality might be migrated to Spring Cloud Task itself.

Author:

Gunnar Hillert, Glenn Renfro, Ilayaperumal Gopinathan

Method Summary

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.
Set<Long>	getAllTaskExecutionIds(boolean onlyCompleted, String taskName) Returns all the task execution IDs of the completed task executions.
Integer	getAllTaskExecutionsCount(boolean onlyCompleted, String taskName) Returns the size of all the task executions with the option to include only the completed executions.
Set<Long>	getTaskExecutionIdsByTaskName(String taskName) Returns the Set of task execution IDs by the given task name.

Method Detail

deleteTaskExecutionParamsByTaskExecutionIds

int deleteTaskExecutionParamsByTaskExecutionIds(Set<Long> taskExecutionIds)

Deletes 1 or more task execution parameter records.

Parameters:

taskExecutionIds - Must contain at least 1 taskExecutionId

Returns:

The number of affected records

deleteTaskExecutionsByTaskExecutionIds

int deleteTaskExecutionsByTaskExecutionIds(Set<Long> taskExecutionIds)

Deletes 1 or more task executions

Parameters:

taskExecutionIds - Must contain at least 1 taskExecutionId

Returns:

The number of affected records

deleteTaskTaskBatchRelationshipsByTaskExecutionIds

int deleteTaskTaskBatchRelationshipsByTaskExecutionIds(Set<Long> taskExecutionIds)

Deletes 1 or more task batch relationship records that links batch executions to task executions.

Parameters:

taskExecutionIds - Must contain at least 1 taskExecutionId

Returns:

The number of affected records

findChildTaskExecutionIds

Set<Long> findChildTaskExecutionIds(Set<Long> taskExecutionIds)

Finds all the child tasks for the taskExecution that is provided.

Parameters:

taskExecutionIds - The ids to theTaskExecutions to be searched

Returns:

a list of child TaskExecutions that correspond to the TaskExecutions passed.

getTaskExecutionIdsByTaskName

Set<Long> getTaskExecutionIdsByTaskName(String taskName)

Returns the Set of task execution IDs by the given task name.

Parameters:

taskName - the task name

Returns:

the Set of task execution IDs

getAllTaskExecutionsCount

Integer getAllTaskExecutionsCount(boolean onlyCompleted,
                                  String taskName)

Returns the size of all the task executions with the option to include only the completed executions.

Parameters:

onlyCompleted - filter by completed task executions

taskName - the task name, if null then retrieve all the tasks

Returns:

The count of task executions matching inputs.

getAllTaskExecutionIds

Set<Long> getAllTaskExecutionIds(boolean onlyCompleted,
                                 String taskName)

Returns all the task execution IDs of the completed task executions.

Parameters:

onlyCompleted - filter by completed task executions

taskName - the task name, if null then retrieve all the tasks

Returns:

The set of all execution ids matching inputs.