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

Interface DataflowTaskExecutionMetadataDao

All Known Implementing Classes:
JdbcDataflowTaskExecutionMetadataDao
public interface DataflowTaskExecutionMetadataDao
Data access object used for manipulating task manifests
Since:
2.3
Author:
Michael Minella, Corneil du Plessis

  • Method Details

    • save

      void save(org.springframework.cloud.task.repository.TaskExecution taskExecution, TaskManifest manifest)
      Saves a TaskManifest related to the supplied TaskExecution
      Parameters:
      taskExecution - execution this manifest is associated with
      manifest - manifest

    • getLatestManifest

      TaskManifest getLatestManifest(String taskName)
      Returns the manifest for the most recently launched instance of the task name requested.
      Parameters:
      taskName - name of task defintion
      Returns:
      TaskManifest

    • findManifestById

      TaskManifest findManifestById(Long id)
      Returns the manifest for the given execution id.
      Parameters:
      id - execution id
      Returns:
      TaskManifest

    • findManifestByIds

      Map<Long,TaskManifest> findManifestByIds(Set<Long> ids)
      Returns a collection of manifests mapped by id for the supplied ids.
      Parameters:
      ids - list of task execution ids.
      Returns:
      map of manifests with id as key.

    • deleteManifestsByTaskExecutionIds

      int deleteManifestsByTaskExecutionIds(Set<Long> taskExecutionIds)
      Deletes the task manifest records associated with the collection of task execution ids provided.
      Parameters:
      taskExecutionIds - collection of ids to delete the manifests for
      Returns:
      number of manifests deleted