A D F G O R S T

A

AggregateDataFlowTaskExecutionQueryDao - Class in org.springframework.cloud.dataflow.aggregate.task.impl

Provide aggregate data for Boot 3 and Boot <=2 TaskExecutions.

AggregateDataFlowTaskExecutionQueryDao(DataSource, SchemaService) - Constructor for class org.springframework.cloud.dataflow.aggregate.task.impl.AggregateDataFlowTaskExecutionQueryDao

Initializes the AggregateDataFlowJobExecutionDao.

AggregateExecutionSupport - Interface in org.springframework.cloud.dataflow.aggregate.task

Allows users to retrieve Task execution and SchemaVersion information from either TaskExecution as well as Task Name.

aggregateExecutionSupport(AppRegistryService, SchemaService) - Method in class org.springframework.cloud.dataflow.aggregate.task.AggregateTaskConfiguration

AggregateTaskConfiguration - Class in org.springframework.cloud.dataflow.aggregate.task

Configuration for aggregate task related components.

AggregateTaskConfiguration() - Constructor for class org.springframework.cloud.dataflow.aggregate.task.AggregateTaskConfiguration

aggregateTaskExplorer(DataSource, DataflowTaskExecutionQueryDao, SchemaService, AggregateExecutionSupport, TaskDefinitionReader, TaskDeploymentReader) - Method in class org.springframework.cloud.dataflow.aggregate.task.AggregateTaskConfiguration

AggregateTaskExplorer - Interface in org.springframework.cloud.dataflow.aggregate.task

Provides for exploring tasks for multiple schema targets.

D

dataflowTaskExecutionQueryDao(DataSource, SchemaService) - Method in class org.springframework.cloud.dataflow.aggregate.task.AggregateTaskConfiguration

DataflowTaskExecutionQueryDao - Interface in org.springframework.cloud.dataflow.aggregate.task

Repository to access TaskExecutions.

DefaultAggregateExecutionSupport - Class in org.springframework.cloud.dataflow.aggregate.task.impl

Provides support for access to SchemaVersionTarget information and conversion of execution data to composite executions.

DefaultAggregateExecutionSupport(AppRegistryService, SchemaService) - Constructor for class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateExecutionSupport

DefaultAggregateTaskExplorer - Class in org.springframework.cloud.dataflow.aggregate.task.impl

Implements CompositeTaskExplorer.

DefaultAggregateTaskExplorer(DataSource, DataflowTaskExecutionQueryDao, SchemaService, AggregateExecutionSupport, TaskDefinitionReader, TaskDeploymentReader) - Constructor for class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateTaskExplorer

DefaultTaskRepositoryContainer - Class in org.springframework.cloud.dataflow.aggregate.task.impl

This class manages a collection of TaskRepositories for all schemas.

DefaultTaskRepositoryContainer(DataSource, SchemaService) - Constructor for class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultTaskRepositoryContainer

F

findAll(Pageable) - Method in interface org.springframework.cloud.dataflow.aggregate.task.AggregateTaskExplorer

Retrieves all the task executions within the pageable constraints sorted by start date descending, taskExecution id descending.

findAll(Pageable, boolean) - Method in interface org.springframework.cloud.dataflow.aggregate.task.AggregateTaskExplorer

Retrieves all the task executions within the pageable constraints sorted by start date descending, taskExecution id descending.

findAll(Pageable) - Method in interface org.springframework.cloud.dataflow.aggregate.task.DataflowTaskExecutionQueryDao

Retrieves all the task executions within the pageable constraints.

findAll(Pageable, boolean) - Method in interface org.springframework.cloud.dataflow.aggregate.task.DataflowTaskExecutionQueryDao

Retrieves all the task executions within the pageable constraints.

findAll(Pageable) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.AggregateDataFlowTaskExecutionQueryDao

findAll(Pageable, boolean) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.AggregateDataFlowTaskExecutionQueryDao

findAll(Pageable) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateTaskExplorer

findAll(Pageable, boolean) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateTaskExplorer

findByDefinitionName(String) - Method in interface org.springframework.cloud.dataflow.aggregate.task.TaskDeploymentReader

findChildTaskExecutions(long, String) - Method in interface org.springframework.cloud.dataflow.aggregate.task.AggregateTaskExplorer

findChildTaskExecutions(Collection<Long>, String) - Method in interface org.springframework.cloud.dataflow.aggregate.task.AggregateTaskExplorer

findChildTaskExecutions(long, String) - Method in interface org.springframework.cloud.dataflow.aggregate.task.DataflowTaskExecutionQueryDao

Retrieves a list of task executions where the provided execution id and schemaTarget represents the parent of task execution.

findChildTaskExecutions(Collection<Long>, String) - Method in interface org.springframework.cloud.dataflow.aggregate.task.DataflowTaskExecutionQueryDao

Retrieves a list of task executions where the provided execution ids and schemaTarget represents the parents of task executions.

findChildTaskExecutions(long, String) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.AggregateDataFlowTaskExecutionQueryDao

findChildTaskExecutions(Collection<Long>, String) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.AggregateDataFlowTaskExecutionQueryDao

findChildTaskExecutions(long, String) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateTaskExplorer

findChildTaskExecutions(Collection<Long>, String) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateTaskExplorer

findRunningTaskExecutions(String, Pageable) - Method in interface org.springframework.cloud.dataflow.aggregate.task.AggregateTaskExplorer

Retrieve a collection of taskExecutions that have the task name provided.

findRunningTaskExecutions(String, Pageable) - Method in interface org.springframework.cloud.dataflow.aggregate.task.DataflowTaskExecutionQueryDao

Retrieves a set of task executions that are running for a taskName.

findRunningTaskExecutions(String, Pageable) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.AggregateDataFlowTaskExecutionQueryDao

findRunningTaskExecutions(String, Pageable) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateTaskExplorer

findSchemaVersionTarget(String, TaskDefinitionReader) - Method in interface org.springframework.cloud.dataflow.aggregate.task.AggregateExecutionSupport

Retrieves the SchemaVersionTarget for the task name.

findSchemaVersionTarget(String, String, TaskDefinitionReader) - Method in interface org.springframework.cloud.dataflow.aggregate.task.AggregateExecutionSupport

findSchemaVersionTarget(String, TaskDefinition) - Method in interface org.springframework.cloud.dataflow.aggregate.task.AggregateExecutionSupport

findSchemaVersionTarget(String, String, TaskDefinition) - Method in interface org.springframework.cloud.dataflow.aggregate.task.AggregateExecutionSupport

findSchemaVersionTarget(String, TaskDefinitionReader) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateExecutionSupport

findSchemaVersionTarget(String, String, TaskDefinitionReader) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateExecutionSupport

findSchemaVersionTarget(String, TaskDefinition) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateExecutionSupport

findSchemaVersionTarget(String, String, TaskDefinition) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateExecutionSupport

findTaskAppRegistration(String) - Method in interface org.springframework.cloud.dataflow.aggregate.task.AggregateExecutionSupport

Retrieve the AppRegistration for the registeredName.

findTaskAppRegistration(String, String) - Method in interface org.springframework.cloud.dataflow.aggregate.task.AggregateExecutionSupport

findTaskAppRegistration(String) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateExecutionSupport

findTaskAppRegistration(String, String) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateExecutionSupport

findTaskDefinition(String) - Method in interface org.springframework.cloud.dataflow.aggregate.task.TaskDefinitionReader

findTaskExecutions(String, boolean) - Method in interface org.springframework.cloud.dataflow.aggregate.task.AggregateTaskExplorer

Get a list of executions for a task by name and completion status.

findTaskExecutions(String, boolean) - Method in interface org.springframework.cloud.dataflow.aggregate.task.DataflowTaskExecutionQueryDao

Find task executions by task name and completion status.

findTaskExecutions(String, boolean) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.AggregateDataFlowTaskExecutionQueryDao

findTaskExecutions(String, boolean) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateTaskExplorer

findTaskExecutionsBeforeEndTime(String, Date) - Method in interface org.springframework.cloud.dataflow.aggregate.task.AggregateTaskExplorer

Get a list of executions for a task by name, completion status and end time.

findTaskExecutionsBeforeEndTime(String, Date) - Method in interface org.springframework.cloud.dataflow.aggregate.task.DataflowTaskExecutionQueryDao

Find task executions by task name whose end date is before the specified date.

findTaskExecutionsBeforeEndTime(String, Date) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.AggregateDataFlowTaskExecutionQueryDao

findTaskExecutionsBeforeEndTime(String, Date) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateTaskExplorer

findTaskExecutionsByName(String, Pageable) - Method in interface org.springframework.cloud.dataflow.aggregate.task.AggregateTaskExplorer

Get a collection/page of executions.

findTaskExecutionsByName(String, Pageable) - Method in interface org.springframework.cloud.dataflow.aggregate.task.DataflowTaskExecutionQueryDao

Retrieves a subset of task executions by task name, start location and size.

findTaskExecutionsByName(String, Pageable) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.AggregateDataFlowTaskExecutionQueryDao

findTaskExecutionsByName(String, Pageable) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateTaskExplorer

from(TaskExecution, TaskDefinitionReader, TaskDeploymentReader) - Method in interface org.springframework.cloud.dataflow.aggregate.task.AggregateExecutionSupport

Retrieves the AggregateTaskExecution for the task execution and TaskDefinitionReader provided.

from(TaskExecution, String, String) - Method in interface org.springframework.cloud.dataflow.aggregate.task.AggregateExecutionSupport

Return the AggregateTaskExecution for the TaskExecution and Schema Target name specified.

from(TaskExecution, TaskDefinitionReader, TaskDeploymentReader) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateExecutionSupport

from(TaskExecution, String, String) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateExecutionSupport

FROM_CLAUSE - Static variable in class org.springframework.cloud.dataflow.aggregate.task.impl.AggregateDataFlowTaskExecutionQueryDao

FROM clause for task execution.

G

get(String) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultTaskRepositoryContainer

get(String) - Method in interface org.springframework.cloud.dataflow.aggregate.task.TaskRepositoryContainer

geTaskExecutionByExecutionId(String, String) - Method in interface org.springframework.cloud.dataflow.aggregate.task.DataflowTaskExecutionQueryDao

geTaskExecutionByExecutionId(String, String) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.AggregateDataFlowTaskExecutionQueryDao

getCompletedTaskExecutionCountByTaskName(String) - Method in interface org.springframework.cloud.dataflow.aggregate.task.DataflowTaskExecutionQueryDao

Retrieves current number of task executions for a taskName and with a non-null endTime.

getCompletedTaskExecutionCountByTaskName(String) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.AggregateDataFlowTaskExecutionQueryDao

getCompletedTaskExecutionCountByTaskNameAndBeforeDate(String, Date) - Method in interface org.springframework.cloud.dataflow.aggregate.task.DataflowTaskExecutionQueryDao

Retrieves current number of task executions for a taskName and with a non-null endTime before the specified date.

getCompletedTaskExecutionCountByTaskNameAndBeforeDate(String, Date) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.AggregateDataFlowTaskExecutionQueryDao

getDeployment(String) - Method in interface org.springframework.cloud.dataflow.aggregate.task.TaskDeploymentReader

getDeployment(String, String) - Method in interface org.springframework.cloud.dataflow.aggregate.task.TaskDeploymentReader

getJobExecutionIdsByTaskExecutionId(long, String) - Method in interface org.springframework.cloud.dataflow.aggregate.task.AggregateTaskExplorer

Returns a Set of JobExecution ids for the jobs that were executed within the scope of the requested task.

getJobExecutionIdsByTaskExecutionId(long, String) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateTaskExplorer

getLatestTaskExecutionForTaskName(String) - Method in interface org.springframework.cloud.dataflow.aggregate.task.AggregateTaskExplorer

Returns the latest task execution for a given task name.

getLatestTaskExecutionForTaskName(String) - Method in interface org.springframework.cloud.dataflow.aggregate.task.DataflowTaskExecutionQueryDao

Returns the latest task execution for a given task name.

getLatestTaskExecutionForTaskName(String) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.AggregateDataFlowTaskExecutionQueryDao

getLatestTaskExecutionForTaskName(String) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateTaskExplorer

getLatestTaskExecutionsByTaskNames(String...) - Method in interface org.springframework.cloud.dataflow.aggregate.task.AggregateTaskExplorer

Returns a List of the latest TaskExecution for 1 or more task names.

getLatestTaskExecutionsByTaskNames(String...) - Method in interface org.springframework.cloud.dataflow.aggregate.task.DataflowTaskExecutionQueryDao

Returns a List of the latest TaskExecution for 1 or more task names.

getLatestTaskExecutionsByTaskNames(String...) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.AggregateDataFlowTaskExecutionQueryDao

getLatestTaskExecutionsByTaskNames(String...) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateTaskExplorer

getRunningTaskExecutionCount() - Method in interface org.springframework.cloud.dataflow.aggregate.task.AggregateTaskExplorer

Retrieves current number of running task executions.

getRunningTaskExecutionCount() - Method in interface org.springframework.cloud.dataflow.aggregate.task.DataflowTaskExecutionQueryDao

Retrieves current number of task executions with an endTime of null.

getRunningTaskExecutionCount() - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.AggregateDataFlowTaskExecutionQueryDao

getRunningTaskExecutionCount() - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateTaskExplorer

getRunningTaskExecutionCountByTaskName(String) - Method in interface org.springframework.cloud.dataflow.aggregate.task.DataflowTaskExecutionQueryDao

Retrieves current number of task executions for a taskName and with an endTime of null.

getRunningTaskExecutionCountByTaskName(String) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.AggregateDataFlowTaskExecutionQueryDao

getTaskExecution(long, String) - Method in interface org.springframework.cloud.dataflow.aggregate.task.AggregateTaskExplorer

find a task execution given an execution id and schema target.

getTaskExecution(long, String) - Method in interface org.springframework.cloud.dataflow.aggregate.task.DataflowTaskExecutionQueryDao

Retrieves a task execution from the task repository.

getTaskExecution(long, String) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.AggregateDataFlowTaskExecutionQueryDao

getTaskExecution(long, String) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateTaskExplorer

getTaskExecutionByExternalExecutionId(String, String) - Method in interface org.springframework.cloud.dataflow.aggregate.task.AggregateTaskExplorer

find a task execution given an external execution id and platform name.

getTaskExecutionByExternalExecutionId(String, String) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateTaskExplorer

getTaskExecutionCount() - Method in interface org.springframework.cloud.dataflow.aggregate.task.AggregateTaskExplorer

Retrieves current number of task executions.

getTaskExecutionCount() - Method in interface org.springframework.cloud.dataflow.aggregate.task.DataflowTaskExecutionQueryDao

Retrieves current number of task executions.

getTaskExecutionCount() - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.AggregateDataFlowTaskExecutionQueryDao

getTaskExecutionCount() - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateTaskExplorer

getTaskExecutionCountByTaskName(String) - Method in interface org.springframework.cloud.dataflow.aggregate.task.AggregateTaskExplorer

Get number of executions for a taskName.

getTaskExecutionCountByTaskName(String) - Method in interface org.springframework.cloud.dataflow.aggregate.task.DataflowTaskExecutionQueryDao

Retrieves current number of task executions for a taskName.

getTaskExecutionCountByTaskName(String) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.AggregateDataFlowTaskExecutionQueryDao

getTaskExecutionCountByTaskName(String) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateTaskExplorer

getTaskExecutionIdByJobExecutionId(long, String) - Method in interface org.springframework.cloud.dataflow.aggregate.task.AggregateTaskExplorer

Returns the id of the TaskExecution that the requested Spring Batch job execution was executed within the context of.

getTaskExecutionIdByJobExecutionId(long, String) - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateTaskExplorer

getTaskNames() - Method in interface org.springframework.cloud.dataflow.aggregate.task.AggregateTaskExplorer

Retrieve a list of available task names.

getTaskNames() - Method in interface org.springframework.cloud.dataflow.aggregate.task.DataflowTaskExecutionQueryDao

Retrieves a sorted list of distinct task names for the task executions.

getTaskNames() - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.AggregateDataFlowTaskExecutionQueryDao

getTaskNames() - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateTaskExplorer

O

org.springframework.cloud.dataflow.aggregate.task - package org.springframework.cloud.dataflow.aggregate.task

org.springframework.cloud.dataflow.aggregate.task.impl - package org.springframework.cloud.dataflow.aggregate.task.impl

R

RUNNING_TASK_WHERE_CLAUSE - Static variable in class org.springframework.cloud.dataflow.aggregate.task.impl.AggregateDataFlowTaskExecutionQueryDao

WHERE clause for running task.

S

SELECT_CLAUSE - Static variable in class org.springframework.cloud.dataflow.aggregate.task.impl.AggregateDataFlowTaskExecutionQueryDao

SELECT clause for task execution.

setup() - Method in class org.springframework.cloud.dataflow.aggregate.task.AggregateTaskConfiguration

setup() - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultAggregateTaskExplorer

setup() - Method in class org.springframework.cloud.dataflow.aggregate.task.impl.DefaultTaskRepositoryContainer

T

TASK_NAME_WHERE_CLAUSE - Static variable in class org.springframework.cloud.dataflow.aggregate.task.impl.AggregateDataFlowTaskExecutionQueryDao

WHERE clause for task name.

TaskDefinitionReader - Interface in org.springframework.cloud.dataflow.aggregate.task

TaskDeploymentReader - Interface in org.springframework.cloud.dataflow.aggregate.task

taskRepositoryContainer(DataSource, SchemaService) - Method in class org.springframework.cloud.dataflow.aggregate.task.AggregateTaskConfiguration

TaskRepositoryContainer - Interface in org.springframework.cloud.dataflow.aggregate.task

A D F G O R S T