org.springframework.cloud.dataflow.server.repository

Interface AggregateJobQueryDao

All Known Implementing Classes:

JdbcAggregateJobQueryDao

public interface AggregateJobQueryDao

Provides for reading job execution data for Batch 4 and 5 schema versions.

Since:

2.11.0

Author:

Corneil du Plessis

Method Summary

Modifier and Type	Method and Description
TaskJobExecution	getJobExecution(long id, String schemaTarget)
org.springframework.batch.core.JobInstance	getJobInstance(long id, String schemaTarget)
JobInstanceExecutions	getJobInstanceExecution(String jobName, long instanceId)
JobInstanceExecutions	getJobInstanceExecutions(long id, String schemaTarget)
org.springframework.data.domain.Page<TaskJobExecution>	listJobExecutions(String jobName, org.springframework.batch.core.BatchStatus status, org.springframework.data.domain.Pageable pageable)
org.springframework.data.domain.Page<TaskJobExecution>	listJobExecutionsBetween(Date fromDate, Date toDate, org.springframework.data.domain.Pageable pageable)
org.springframework.data.domain.Page<TaskJobExecution>	listJobExecutionsForJobWithStepCount(String jobName, org.springframework.data.domain.Pageable pageable)
org.springframework.data.domain.Page<TaskJobExecution>	listJobExecutionsForJobWithStepCountFilteredByJobInstanceId(int jobInstanceId, String schemaTarget, org.springframework.data.domain.Pageable pageable)
org.springframework.data.domain.Page<TaskJobExecution>	listJobExecutionsForJobWithStepCountFilteredByTaskExecutionId(int taskExecutionId, String schemaTarget, org.springframework.data.domain.Pageable pageable)
org.springframework.data.domain.Page<TaskJobExecution>	listJobExecutionsWithStepCount(org.springframework.data.domain.Pageable pageable)
org.springframework.data.domain.Page<TaskJobExecution>	listJobExecutionsWithSteps(org.springframework.data.domain.Pageable pageable)
org.springframework.data.domain.Page<JobInstanceExecutions>	listJobInstances(String jobName, org.springframework.data.domain.Pageable pageable)

Method Detail

listJobInstances

org.springframework.data.domain.Page<JobInstanceExecutions> listJobInstances(String jobName,
                                                                             org.springframework.data.domain.Pageable pageable)
                                                                      throws org.springframework.batch.core.launch.NoSuchJobException

Throws:

org.springframework.batch.core.launch.NoSuchJobException

listJobExecutions

org.springframework.data.domain.Page<TaskJobExecution> listJobExecutions(String jobName,
                                                                         org.springframework.batch.core.BatchStatus status,
                                                                         org.springframework.data.domain.Pageable pageable)
                                                                  throws org.springframework.batch.core.launch.NoSuchJobExecutionException

Throws:

org.springframework.batch.core.launch.NoSuchJobExecutionException

listJobExecutionsBetween

org.springframework.data.domain.Page<TaskJobExecution> listJobExecutionsBetween(Date fromDate,
                                                                                Date toDate,
                                                                                org.springframework.data.domain.Pageable pageable)

listJobExecutionsWithSteps

org.springframework.data.domain.Page<TaskJobExecution> listJobExecutionsWithSteps(org.springframework.data.domain.Pageable pageable)

listJobExecutionsWithStepCount

org.springframework.data.domain.Page<TaskJobExecution> listJobExecutionsWithStepCount(org.springframework.data.domain.Pageable pageable)

listJobExecutionsForJobWithStepCountFilteredByJobInstanceId

org.springframework.data.domain.Page<TaskJobExecution> listJobExecutionsForJobWithStepCountFilteredByJobInstanceId(int jobInstanceId,
                                                                                                                   String schemaTarget,
                                                                                                                   org.springframework.data.domain.Pageable pageable)

listJobExecutionsForJobWithStepCountFilteredByTaskExecutionId

org.springframework.data.domain.Page<TaskJobExecution> listJobExecutionsForJobWithStepCountFilteredByTaskExecutionId(int taskExecutionId,
                                                                                                                     String schemaTarget,
                                                                                                                     org.springframework.data.domain.Pageable pageable)

listJobExecutionsForJobWithStepCount

org.springframework.data.domain.Page<TaskJobExecution> listJobExecutionsForJobWithStepCount(String jobName,
                                                                                            org.springframework.data.domain.Pageable pageable)
                                                                                     throws org.springframework.batch.core.launch.NoSuchJobException

Throws:

org.springframework.batch.core.launch.NoSuchJobException

getJobExecution

TaskJobExecution getJobExecution(long id,
                                 String schemaTarget)
                          throws org.springframework.batch.core.launch.NoSuchJobExecutionException

Throws:

org.springframework.batch.core.launch.NoSuchJobExecutionException

getJobInstanceExecution

JobInstanceExecutions getJobInstanceExecution(String jobName,
                                              long instanceId)

getJobInstanceExecutions

JobInstanceExecutions getJobInstanceExecutions(long id,
                                               String schemaTarget)

getJobInstance

org.springframework.batch.core.JobInstance getJobInstance(long id,
                                                          String schemaTarget)
                                                   throws org.springframework.batch.core.launch.NoSuchJobInstanceException

Throws:

org.springframework.batch.core.launch.NoSuchJobInstanceException