Package org.springframework.cloud.dataflow.server.repository

Interface DataflowJobExecutionDao

All Known Implementing Classes:
JdbcDataflowJobExecutionDao
public interface DataflowJobExecutionDao
Repository to access JobExecutions. Mirrors the JobExecutionDao but contains Spring Cloud Data Flow specific operations. This functionality might be migrated to Spring Batch itself eventually.
Author:
Gunnar Hillert

  • Method Details

    • deleteBatchJobExecutionByJobExecutionIds

      int deleteBatchJobExecutionByJobExecutionIds(Set<Long> jobExecutionIds)
      Delete the batch job execution records from the persistence store for the provided job execution ids.
      Parameters:
      jobExecutionIds - Must contain at least 1 value
      Returns:
      The number of affected records

    • deleteBatchJobExecutionContextByJobExecutionIds

      int deleteBatchJobExecutionContextByJobExecutionIds(Set<Long> jobExecutionIds)
      Delete the batch job execution context records from the persistence store for the provided job execution ids.
      Parameters:
      jobExecutionIds - Must contain at least 1 value
      Returns:
      The number of affected records

    • deleteBatchJobExecutionParamsByJobExecutionIds

      int deleteBatchJobExecutionParamsByJobExecutionIds(Set<Long> jobExecutionIds)
      Delete the batch job execution parameter records from the persistence store for the provided job execution ids.
      Parameters:
      jobExecutionIds - Must contain at least 1 value
      Returns:
      The number of affected records

    • deleteBatchStepExecutionContextByStepExecutionIds

      int deleteBatchStepExecutionContextByStepExecutionIds(Set<Long> stepExecutionIds)
      Delete the batch step execution context records from the persistence store for the provided step execution ids.
      Parameters:
      stepExecutionIds - Must contain at least 1 value
      Returns:
      The number of affected records

    • deleteBatchStepExecutionsByJobExecutionIds

      int deleteBatchStepExecutionsByJobExecutionIds(Set<Long> jobExecutionIds)
      Parameters:
      jobExecutionIds - Must contain at least 1 value
      Returns:
      The number of affected records

    • deleteUnusedBatchJobInstances

      int deleteUnusedBatchJobInstances()
      Will delete any unused job instance records from the persistence store.
      Returns:
      The number of affected records

    • findStepExecutionIds

      Set<Long> findStepExecutionIds(Set<Long> jobExecutionIds)
      Retrieve the step execution ids for 1 or more job execution ids.
      Parameters:
      jobExecutionIds - Must contain at least 1 value
      Returns:
      If no step execution ids are found, an empty collection is returned