Package | Description |
---|---|
org.springframework.cloud.dataflow.rest.job |
Defines the Batch Job specific REST domain classes.
|
org.springframework.cloud.dataflow.rest.resource |
Spring Cloud Data Flow REST HATEOAS Resource support.
|
org.springframework.cloud.dataflow.server.controller |
Spring Cloud Data Flow Server Controllers.
|
org.springframework.cloud.dataflow.server.repository |
Spring Cloud Data Flow Server Repositories.
|
org.springframework.cloud.dataflow.server.service |
Contains various Services (Interfaces) that are part of the Dataflow Server.
|
org.springframework.cloud.dataflow.server.service.impl |
Contains Service implementations for the Dataflow Server.
|
Modifier and Type | Method and Description |
---|---|
TaskJobExecution |
TaskJobExecutionRel.getComposedTaskJobExecution() |
Modifier and Type | Method and Description |
---|---|
List<TaskJobExecution> |
JobInstanceExecutions.getTaskJobExecutions() |
Constructor and Description |
---|
TaskJobExecutionRel(org.springframework.cloud.dataflow.schema.AggregateTaskExecution taskExecution,
List<Long> jobExecutionIds,
TaskManifest taskManifest,
TaskJobExecution composedTaskJobExecution)
Constructor that establishes the relationship between a
TaskExecution and
the Job Execution Ids of the jobs that were executed within it. |
Constructor and Description |
---|
JobInstanceExecutions(org.springframework.batch.core.JobInstance jobInstance,
List<TaskJobExecution> taskJobExecutions) |
Constructor and Description |
---|
JobExecutionResource(TaskJobExecution taskJobExecution,
TimeZone timeZone) |
JobExecutionThinResource(TaskJobExecution taskJobExecution,
TimeZone timeZone) |
TaskExecutionResource(org.springframework.cloud.dataflow.schema.AggregateTaskExecution taskExecution,
TaskJobExecution composedTaskJobExecution)
Constructor to initialize the TaskExecutionResource using a
TaskExecution . |
TaskExecutionResource(org.springframework.cloud.dataflow.schema.AggregateTaskExecution taskExecution,
TaskManifest taskManifest,
TaskJobExecution composedTaskJobExecution)
Constructor to initialize the TaskExecutionResource using a
TaskExecution and TaskManifest . |
Modifier and Type | Method and Description |
---|---|
org.springframework.hateoas.PagedModel<JobExecutionThinResource> |
JobExecutionThinController.listJobsOnly(org.springframework.data.domain.Pageable pageable,
org.springframework.data.web.PagedResourcesAssembler<TaskJobExecution> assembler)
Return a page-able list of
JobExecutionThinResource defined jobs that
do not contain step execution detail. |
org.springframework.hateoas.PagedModel<JobExecutionThinResource> |
JobExecutionThinController.retrieveJobsByDateRange(Date fromDate,
Date toDate,
org.springframework.data.domain.Pageable pageable,
org.springframework.data.web.PagedResourcesAssembler<TaskJobExecution> assembler)
Retrieve all task job executions filtered with the date range specified
|
org.springframework.hateoas.PagedModel<JobExecutionThinResource> |
JobExecutionThinController.retrieveJobsByJobInstanceId(int jobInstanceId,
String schemaTarget,
org.springframework.data.domain.Pageable pageable,
org.springframework.data.web.PagedResourcesAssembler<TaskJobExecution> assembler)
Retrieve all task job executions filtered with the job instance id specified
|
org.springframework.hateoas.PagedModel<JobExecutionThinResource> |
JobExecutionThinController.retrieveJobsByName(String jobName,
org.springframework.data.domain.Pageable pageable,
org.springframework.data.web.PagedResourcesAssembler<TaskJobExecution> assembler)
Retrieve all task job executions with the task name specified
|
org.springframework.hateoas.PagedModel<JobExecutionResource> |
JobExecutionController.retrieveJobsByParameters(String jobName,
org.springframework.batch.core.BatchStatus status,
org.springframework.data.domain.Pageable pageable,
org.springframework.data.web.PagedResourcesAssembler<TaskJobExecution> assembler)
Retrieve all task job executions with the task name specified
|
org.springframework.hateoas.PagedModel<JobExecutionThinResource> |
JobExecutionThinController.retrieveJobsByTaskExecutionId(int taskExecutionId,
String schemaTarget,
org.springframework.data.domain.Pageable pageable,
org.springframework.data.web.PagedResourcesAssembler<TaskJobExecution> assembler)
Retrieve all task job executions filtered with the task execution id specified
|
Modifier and Type | Method and Description |
---|---|
TaskJobExecution |
JdbcAggregateJobQueryDao.getJobExecution(long jobExecutionId,
String schemaTarget) |
TaskJobExecution |
AggregateJobQueryDao.getJobExecution(long id,
String schemaTarget) |
Modifier and Type | Method and Description |
---|---|
List<TaskJobExecution> |
JdbcAggregateJobQueryDao.getJobExecutionsWithStepCount(int start,
int count) |
org.springframework.data.domain.Page<TaskJobExecution> |
JdbcAggregateJobQueryDao.listJobExecutions(String jobName,
org.springframework.batch.core.BatchStatus status,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Page<TaskJobExecution> |
AggregateJobQueryDao.listJobExecutions(String jobName,
org.springframework.batch.core.BatchStatus status,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Page<TaskJobExecution> |
JdbcAggregateJobQueryDao.listJobExecutionsBetween(Date fromDate,
Date toDate,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Page<TaskJobExecution> |
AggregateJobQueryDao.listJobExecutionsBetween(Date fromDate,
Date toDate,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Page<TaskJobExecution> |
JdbcAggregateJobQueryDao.listJobExecutionsForJobWithStepCount(String jobName,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Page<TaskJobExecution> |
AggregateJobQueryDao.listJobExecutionsForJobWithStepCount(String jobName,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Page<TaskJobExecution> |
JdbcAggregateJobQueryDao.listJobExecutionsForJobWithStepCountFilteredByJobInstanceId(int jobInstanceId,
String schemaTarget,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Page<TaskJobExecution> |
AggregateJobQueryDao.listJobExecutionsForJobWithStepCountFilteredByJobInstanceId(int jobInstanceId,
String schemaTarget,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Page<TaskJobExecution> |
JdbcAggregateJobQueryDao.listJobExecutionsForJobWithStepCountFilteredByTaskExecutionId(int taskExecutionId,
String schemaTarget,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Page<TaskJobExecution> |
AggregateJobQueryDao.listJobExecutionsForJobWithStepCountFilteredByTaskExecutionId(int taskExecutionId,
String schemaTarget,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Page<TaskJobExecution> |
JdbcAggregateJobQueryDao.listJobExecutionsWithStepCount(org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Page<TaskJobExecution> |
AggregateJobQueryDao.listJobExecutionsWithStepCount(org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Page<TaskJobExecution> |
JdbcAggregateJobQueryDao.listJobExecutionsWithSteps(org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Page<TaskJobExecution> |
AggregateJobQueryDao.listJobExecutionsWithSteps(org.springframework.data.domain.Pageable pageable) |
Modifier and Type | Method and Description |
---|---|
TaskJobExecution |
TaskJobService.getJobExecution(long id,
String schemaTarget)
Retrieves a JobExecution from the JobRepository and matches it with a task id.
|
Modifier and Type | Method and Description |
---|---|
org.springframework.data.domain.Page<TaskJobExecution> |
TaskJobService.listJobExecutions(org.springframework.data.domain.Pageable pageable)
Retrieves Pageable list of
JobExecution s from the JobRepository and matches the
data with a task id. |
org.springframework.data.domain.Page<TaskJobExecution> |
TaskJobService.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. |
org.springframework.data.domain.Page<TaskJobExecution> |
TaskJobService.listJobExecutionsForJobWithStepCount(org.springframework.data.domain.Pageable pageable,
Date fromDate,
Date toDate)
Retrieves Pageable list of
JobExecutionWithStepCount from the JobRepository
filtered by the date range. |
org.springframework.data.domain.Page<TaskJobExecution> |
TaskJobService.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. |
org.springframework.data.domain.Page<TaskJobExecution> |
TaskJobService.listJobExecutionsForJobWithStepCountFilteredByJobInstanceId(org.springframework.data.domain.Pageable pageable,
int jobInstanceId,
String schemaTarget)
Retrieves Pageable list of
JobExecutionWithStepCount from the JobRepository
filtered by the job instance id. |
org.springframework.data.domain.Page<TaskJobExecution> |
TaskJobService.listJobExecutionsForJobWithStepCountFilteredByTaskExecutionId(org.springframework.data.domain.Pageable pageable,
int taskExecutionId,
String schemaTarget)
Retrieves Pageable list of
JobExecutionWithStepCount from the JobRepository
filtered by the task execution id. |
org.springframework.data.domain.Page<TaskJobExecution> |
TaskJobService.listJobExecutionsWithStepCount(org.springframework.data.domain.Pageable pageable)
Retrieves Pageable list of
JobExecutionWithStepCount s from the JobRepository
and matches the data with a task id but excludes the step executions. |
Modifier and Type | Method and Description |
---|---|
TaskJobExecution |
DefaultTaskJobService.getJobExecution(long id,
String schemaTarget) |
Modifier and Type | Method and Description |
---|---|
org.springframework.data.domain.Page<TaskJobExecution> |
DefaultTaskJobService.listJobExecutions(org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Page<TaskJobExecution> |
DefaultTaskJobService.listJobExecutionsForJob(org.springframework.data.domain.Pageable pageable,
String jobName,
org.springframework.batch.core.BatchStatus status) |
org.springframework.data.domain.Page<TaskJobExecution> |
DefaultTaskJobService.listJobExecutionsForJobWithStepCount(org.springframework.data.domain.Pageable pageable,
Date fromDate,
Date toDate) |
org.springframework.data.domain.Page<TaskJobExecution> |
DefaultTaskJobService.listJobExecutionsForJobWithStepCount(org.springframework.data.domain.Pageable pageable,
String jobName) |
org.springframework.data.domain.Page<TaskJobExecution> |
DefaultTaskJobService.listJobExecutionsForJobWithStepCountFilteredByJobInstanceId(org.springframework.data.domain.Pageable pageable,
int jobInstanceId,
String schemaTarget) |
org.springframework.data.domain.Page<TaskJobExecution> |
DefaultTaskJobService.listJobExecutionsForJobWithStepCountFilteredByTaskExecutionId(org.springframework.data.domain.Pageable pageable,
int taskExecutionId,
String schemaTarget) |
org.springframework.data.domain.Page<TaskJobExecution> |
DefaultTaskJobService.listJobExecutionsWithStepCount(org.springframework.data.domain.Pageable pageable) |
Copyright © 2024 Pivotal Software, Inc.. All rights reserved.