@Transactional public class DefaultTaskJobService extends Object implements TaskJobService
| Constructor and Description |
|---|
DefaultTaskJobService(JobService jobService,
org.springframework.cloud.task.repository.TaskExplorer taskExplorer,
TaskDefinitionRepository taskDefinitionRepository,
TaskExecutionService taskExecutionService) |
| Modifier and Type | Method and Description |
|---|---|
int |
countJobExecutions()
Retrieves the total number of the job executions.
|
int |
countJobExecutionsForJob(String jobName,
org.springframework.batch.core.BatchStatus status)
Retrieves the total number
JobExecution that match a specific job name. |
int |
countJobInstances(String jobName)
Retrieves the total number of job instances for a job name.
|
TaskJobExecution |
getJobExecution(long id)
Retrieves a JobExecution from the JobRepository and matches it with a task id.
|
JobInstanceExecutions |
getJobInstance(long id)
Retrieves a
JobInstance from the JobRepository and matches it with the
associated JobExecutions. |
List<TaskJobExecution> |
listJobExecutions(org.springframework.data.domain.Pageable pageable)
Retrieves Pageable list of
JobExecutions from the JobRepository and matches the
data with a task id. |
List<TaskJobExecution> |
listJobExecutionsForJob(org.springframework.data.domain.Pageable pageable,
String jobName,
org.springframework.batch.core.BatchStatus status)
Retrieves Pageable list of
JobExecution from the JobRepository with a specific
jobName, status and matches the data with a task id. |
List<TaskJobExecution> |
listJobExecutionsForJobWithStepCount(org.springframework.data.domain.Pageable pageable,
Date fromDate,
Date toDate)
Retrieves Pageable list of
JobExecutionWithStepCount from the JobRepository
filtered by the date range. |
List<TaskJobExecution> |
listJobExecutionsForJobWithStepCount(org.springframework.data.domain.Pageable pageable,
String jobName)
Retrieves Pageable list of
JobExecutionWithStepCount from the JobRepository
with a specific jobName and matches the data with a task id. |
List<TaskJobExecution> |
listJobExecutionsForJobWithStepCountFilteredByJobInstanceId(org.springframework.data.domain.Pageable pageable,
int jobInstanceId)
Retrieves Pageable list of
JobExecutionWithStepCount from the JobRepository
filtered by the job instance id. |
List<TaskJobExecution> |
listJobExecutionsForJobWithStepCountFilteredByTaskExecutionId(org.springframework.data.domain.Pageable pageable,
int taskExecutionId)
Retrieves Pageable list of
JobExecutionWithStepCount from the JobRepository
filtered by the task execution id. |
List<TaskJobExecution> |
listJobExecutionsWithStepCount(org.springframework.data.domain.Pageable pageable)
Retrieves Pageable list of
JobExecutionWithStepCounts from the JobRepository
and matches the data with a task id but excludes the step executions. |
List<JobInstanceExecutions> |
listTaskJobInstancesForJobName(org.springframework.data.domain.Pageable pageable,
String jobName)
Retrieves Pageable list of
JobInstanceExecutions from the JobRepository with a
specific jobName and matches the data with the associated JobExecutions. |
void |
restartJobExecution(long jobExecutionId)
Restarts a
JobExecution IF the respective JobExecution is actually
deemed restartable. |
void |
stopJobExecution(long jobExecutionId)
Requests a
JobExecution to stop. |
public DefaultTaskJobService(JobService jobService, org.springframework.cloud.task.repository.TaskExplorer taskExplorer, TaskDefinitionRepository taskDefinitionRepository, TaskExecutionService taskExecutionService)
public List<TaskJobExecution> listJobExecutions(org.springframework.data.domain.Pageable pageable) throws org.springframework.batch.core.launch.NoSuchJobExecutionException
TaskJobServiceJobExecutions from the JobRepository and matches the
data with a task id.listJobExecutions in interface TaskJobServicepageable - enumerates the data to be returned.TaskJobExecutions.org.springframework.batch.core.launch.NoSuchJobExecutionException - in the event that a job execution id specified is
not present when looking up stepExecutions for the result.public List<TaskJobExecution> listJobExecutionsWithStepCount(org.springframework.data.domain.Pageable pageable)
TaskJobServiceJobExecutionWithStepCounts from the JobRepository
and matches the data with a task id but excludes the step executions.listJobExecutionsWithStepCount in interface TaskJobServicepageable - enumerates the data to be returned.TaskJobExecutions.public List<TaskJobExecution> listJobExecutionsForJob(org.springframework.data.domain.Pageable pageable, String jobName, org.springframework.batch.core.BatchStatus status) throws org.springframework.batch.core.launch.NoSuchJobException
TaskJobServiceJobExecution from the JobRepository with a specific
jobName, status and matches the data with a task id.listJobExecutionsForJob in interface TaskJobServicepageable - enumerates the data to be returned.jobName - the name of the job for which to findByTaskNameContains.status - the BatchStatus of the job execution.TaskJobExecutions.org.springframework.batch.core.launch.NoSuchJobException - if the job with the given name does not exist.public List<TaskJobExecution> listJobExecutionsForJobWithStepCount(org.springframework.data.domain.Pageable pageable, Date fromDate, Date toDate)
TaskJobServiceJobExecutionWithStepCount from the JobRepository
filtered by the date range.listJobExecutionsForJobWithStepCount in interface TaskJobServicepageable - enumerates the data to be returned.fromDate - the date which start date must be greater than.toDate - the date which start date must be less than.JobExecutionWithStepCounts.public List<TaskJobExecution> listJobExecutionsForJobWithStepCountFilteredByJobInstanceId(org.springframework.data.domain.Pageable pageable, int jobInstanceId) throws org.springframework.batch.core.launch.NoSuchJobException
TaskJobServiceJobExecutionWithStepCount from the JobRepository
filtered by the job instance id.listJobExecutionsForJobWithStepCountFilteredByJobInstanceId in interface TaskJobServicepageable - enumerates the data to be returned.jobInstanceId - the job instance id associated with the execution.JobExecutionWithStepCounts.org.springframework.batch.core.launch.NoSuchJobException - if the job with the given name does not exist.public List<TaskJobExecution> listJobExecutionsForJobWithStepCountFilteredByTaskExecutionId(org.springframework.data.domain.Pageable pageable, int taskExecutionId) throws org.springframework.batch.core.launch.NoSuchJobException
TaskJobServiceJobExecutionWithStepCount from the JobRepository
filtered by the task execution id.listJobExecutionsForJobWithStepCountFilteredByTaskExecutionId in interface TaskJobServicepageable - enumerates the data to be returned.taskExecutionId - the task execution id associated with the execution.JobExecutionWithStepCounts.org.springframework.batch.core.launch.NoSuchJobException - if the job with the given name does not exist.public List<TaskJobExecution> listJobExecutionsForJobWithStepCount(org.springframework.data.domain.Pageable pageable, String jobName) throws org.springframework.batch.core.launch.NoSuchJobException
TaskJobServiceJobExecutionWithStepCount from the JobRepository
with a specific jobName and matches the data with a task id.listJobExecutionsForJobWithStepCount in interface TaskJobServicepageable - enumerates the data to be returned.jobName - the name of the job for which to findByTaskNameContains.JobExecutionWithStepCounts.org.springframework.batch.core.launch.NoSuchJobException - if the job with the given name does not exist.public TaskJobExecution getJobExecution(long id) throws org.springframework.batch.core.launch.NoSuchJobExecutionException
TaskJobServicegetJobExecution in interface TaskJobServiceid - the id of the JobExecutionTaskJobExecutions associated with the id.org.springframework.batch.core.launch.NoSuchJobExecutionException - if the specified job execution for the id does not
exist.public List<JobInstanceExecutions> listTaskJobInstancesForJobName(org.springframework.data.domain.Pageable pageable, String jobName) throws org.springframework.batch.core.launch.NoSuchJobException
TaskJobServiceJobInstanceExecutions from the JobRepository with a
specific jobName and matches the data with the associated JobExecutions.listTaskJobInstancesForJobName in interface TaskJobServicepageable - enumerates the data to be returned.jobName - the name of the job for which to findByTaskNameContains.JobInstanceExecutions.org.springframework.batch.core.launch.NoSuchJobException - if the job for the jobName specified does not exist.public JobInstanceExecutions getJobInstance(long id) throws org.springframework.batch.core.launch.NoSuchJobInstanceException, org.springframework.batch.core.launch.NoSuchJobException
TaskJobServiceJobInstance from the JobRepository and matches it with the
associated JobExecutions.getJobInstance in interface TaskJobServiceid - the id of the JobInstanceJobInstanceExecutions associated with the id.org.springframework.batch.core.launch.NoSuchJobInstanceException - if job instance id does not exist.org.springframework.batch.core.launch.NoSuchJobException - if the job for the job instance does not exist.public int countJobInstances(String jobName) throws org.springframework.batch.core.launch.NoSuchJobException
TaskJobServicecountJobInstances in interface TaskJobServicejobName - the name of the job instance.org.springframework.batch.core.launch.NoSuchJobException - if the job for jobName specified does not exist.public int countJobExecutions()
TaskJobServicecountJobExecutions in interface TaskJobServicepublic int countJobExecutionsForJob(String jobName, org.springframework.batch.core.BatchStatus status) throws org.springframework.batch.core.launch.NoSuchJobException
TaskJobServiceJobExecution that match a specific job name.countJobExecutionsForJob in interface TaskJobServicejobName - the job name to findByTaskNameContains.status - the status of the job executionJobExecutions that match the job name.org.springframework.batch.core.launch.NoSuchJobException - if the job for the jobName does not exist.public void restartJobExecution(long jobExecutionId)
throws org.springframework.batch.core.launch.NoSuchJobExecutionException
TaskJobServiceJobExecution IF the respective JobExecution is actually
deemed restartable. Otherwise a JobNotRestartableException is being thrown.restartJobExecution in interface TaskJobServicejobExecutionId - The id of the JobExecution to restart.org.springframework.batch.core.launch.NoSuchJobExecutionException - if the JobExecution for the provided id does not
exist.public void stopJobExecution(long jobExecutionId)
throws org.springframework.batch.core.launch.NoSuchJobExecutionException,
org.springframework.batch.core.launch.JobExecutionNotRunningException
TaskJobServiceJobExecution to stop.
Please remember, that calling this method only requests a job execution to stop
processing. This method does not guarantee a JobExecution to stop. It is the
responsibility of the implementor of the Job to react to that request.
Furthermore, this method does not interfere with the associated TaskExecution.
stopJobExecution in interface TaskJobServicejobExecutionId - The id of the JobExecution to stoporg.springframework.batch.core.launch.NoSuchJobExecutionException - thrown if no job execution exists for the
jobExecutionId.org.springframework.batch.core.launch.JobExecutionNotRunningException - thrown if a stop is requested on a job that is
not running.JobService.stop(Long)Copyright © 2021 Pivotal Software, Inc.. All rights reserved.