Package 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 Details

    • 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.