public class DefaultTaskJobService extends Object implements TaskJobService
Constructor and Description |
---|
DefaultTaskJobService(org.springframework.batch.admin.service.JobService jobService,
org.springframework.cloud.task.repository.TaskExplorer taskExplorer,
TaskDefinitionRepository taskDefinitionRepository,
TaskService taskService) |
Modifier and Type | Method and Description |
---|---|
int |
countJobExecutions()
Retrieves the total number of the job executions.
|
int |
countJobExecutionsForJob(String jobName)
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
JobExecution s. |
List<TaskJobExecution> |
listJobExecutions(org.springframework.data.domain.Pageable pageable)
Retrieves Pageable list of
JobExecution s from the JobRepository and matches
the data with a task id. |
List<TaskJobExecution> |
listJobExecutionsForJob(org.springframework.data.domain.Pageable pageable,
String jobName)
Retrieves Pageable list of
JobExecution from the JobRepository with a
specific jobName and matches the data with a task id. |
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(org.springframework.batch.admin.service.JobService jobService, org.springframework.cloud.task.repository.TaskExplorer taskExplorer, TaskDefinitionRepository taskDefinitionRepository, TaskService taskService)
public List<TaskJobExecution> listJobExecutions(org.springframework.data.domain.Pageable pageable) throws org.springframework.batch.core.launch.NoSuchJobExecutionException
JobExecution
s from the JobRepository and matches
the data with a task id.listJobExecutions
in interface TaskJobService
pageable
- enumerates the data to be returned.TaskJobExecution
s.org.springframework.batch.core.launch.NoSuchJobExecutionException
public List<TaskJobExecution> listJobExecutionsForJob(org.springframework.data.domain.Pageable pageable, String jobName) throws org.springframework.batch.core.launch.NoSuchJobException
JobExecution
from the JobRepository with a
specific jobName and matches the data with a task id.listJobExecutionsForJob
in interface TaskJobService
pageable
- enumerates the data to be returned.jobName
- the name of the job for which to search.TaskJobExecution
s.org.springframework.batch.core.launch.NoSuchJobException
public TaskJobExecution getJobExecution(long id) throws org.springframework.batch.core.launch.NoSuchJobExecutionException
getJobExecution
in interface TaskJobService
id
- the id of the JobExecution
TaskJobExecution
s associated with the id.org.springframework.batch.core.launch.NoSuchJobExecutionException
public List<JobInstanceExecutions> listTaskJobInstancesForJobName(org.springframework.data.domain.Pageable pageable, String jobName) throws org.springframework.batch.core.launch.NoSuchJobException
JobInstanceExecutions
from the JobRepository with a
specific jobName and matches the data with the associated JobExecutions.listTaskJobInstancesForJobName
in interface TaskJobService
pageable
- enumerates the data to be returned.jobName
- the name of the job for which to search.JobInstanceExecutions
.org.springframework.batch.core.launch.NoSuchJobException
public JobInstanceExecutions getJobInstance(long id) throws org.springframework.batch.core.launch.NoSuchJobInstanceException, org.springframework.batch.core.launch.NoSuchJobException
JobInstance
from the JobRepository and matches it with the associated
JobExecution
s.getJobInstance
in interface TaskJobService
id
- the id of the JobInstance
JobInstanceExecutions
associated with the id.org.springframework.batch.core.launch.NoSuchJobInstanceException
org.springframework.batch.core.launch.NoSuchJobException
public int countJobInstances(String jobName) throws org.springframework.batch.core.launch.NoSuchJobException
countJobInstances
in interface TaskJobService
jobName
- the name of the job instance.org.springframework.batch.core.launch.NoSuchJobException
public int countJobExecutions()
countJobExecutions
in interface TaskJobService
public int countJobExecutionsForJob(String jobName) throws org.springframework.batch.core.launch.NoSuchJobException
JobExecution
that match a specific job name.countJobExecutionsForJob
in interface TaskJobService
jobName
- the job name to search.JobExecution
s that match the job name.org.springframework.batch.core.launch.NoSuchJobException
public void restartJobExecution(long jobExecutionId) throws org.springframework.batch.core.launch.NoSuchJobExecutionException
TaskJobService
JobExecution
IF the respective JobExecution
is actually deemed restartable. Otherwise a JobNotRestartableException
is being thrown.restartJobExecution
in interface TaskJobService
jobExecutionId
- The id of the JobExecution to restartorg.springframework.batch.core.launch.NoSuchJobExecutionException
- Thrown if the JobExecution for the provided id does not existpublic void stopJobExecution(long jobExecutionId) throws org.springframework.batch.core.launch.NoSuchJobExecutionException, org.springframework.batch.core.launch.JobExecutionNotRunningException
TaskJobService
JobExecution
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 TaskJobService
jobExecutionId
- The id of the JobExecution
to stoporg.springframework.batch.core.launch.NoSuchJobExecutionException
org.springframework.batch.core.launch.JobExecutionNotRunningException
JobService.stop(Long)
Copyright © 2017 Pivotal Software, Inc.. All rights reserved.