All Classes and Interfaces
Class
Description
Abstract SQL Paging Query Provider to serve as a base class for all provided SQL paging
query providers.
Autconfiguration for a
AmqpItemReader.Properties to configure a
AmqpItemReader.Autconfiguration for a
AmqpItemWriter.Autoconfigures Spring Batch listeners designed to emit events on the following
channels.
Configuration for Job Execution Listener.
Headers definitions used by the batch job plugin.
Strategy to allow for the customization of command line arguments passed to each
partition's execution.
Enum representing a database type, such as DB2 or oracle.
IBM DB2 implementation of a
PagingQueryProvider using
database specific features.Default implementation of the TaskConfigurer interface.
A
PartitionHandler implementation that delegates to a TaskLauncher for
each of the workers.
A
CommandLineRunner used to execute a Step.Creates two data sources that use embedded databases.
Enables the
TaskLifecycleListener so
that the features of Spring Cloud Task will be applied.
Enable this boot app to be a sink to receive a
TaskLaunchRequest and use the
TaskLauncher to launch the task.Strategy interface to allow for advanced configuration of environment variables for
each worker in a partitioned job.
Provides informational messages around the
Chunk of a batch job.Provides informational messages around the
ItemProcessListener of a batch job.Provides informational messages around the
ItemReader of a batch job.Setups up the ItemWriteEventsListener to emit events to the spring cloud stream output
channel.
Provides
JobExecutionEvent at both the start and end of the job's execution.Setups up the SkipProcessListener to emit events to the spring cloud stream output
channel.
Provides a
StepExecutionEvent at the start and end of each step indicating the
step's status.ExitStatus DTO created so that
ExitStatus can be
serialized into Json without.Creates two data sources that use external databases.
Autconfiguration for a
FlatFileItemReader.A
FieldSetMapper that takes a FieldSet and returns the
Map<String, Object> of its contents.Properties to configure a
FlatFileItemReader.Autoconfiguration for a
FlatFileItemWriter.A
FieldExtractor that converts a Map<String, Object> to the ordered
Object[] required to populate an output record.Properties for configuring a
FlatFileItemWriter.H2 implementation of a
PagingQueryProvider using database specific features.HSQLDB implementation of a
PagingQueryProvider using database specific
features.Autconfiguration for a
JdbcBatchItemWriter.Properties to configure a
JdbcBatchItemWriter.JDBC based implementation of the
TaskBatchDao.Stores Task Execution Information to a JDBC DataSource.
This is a JobEvent DTO created so that a
JobExecution can be serialized into Json without
having to add mixins to an ObjectMapper.This is a JobInstance DTO created so that a
JobInstance can be serialized into Json without
having to add mixins to an ObjectMapper.Evaluates if the correct conditions have been met to create a TaskJobLauncher.
This is a JobParameter DTO created so that a
JobParameter can be serialized into Json without
having to add mixins to an ObjectMapper.Enumeration representing the type of a JobParameter.
This is a JobParametersEvent DTO created so that a
JobParameters can be serialized into Json
without having to add mixins to an ObjectMapper.AutoConfiguration for a
KafkaItemReader.Properties to configure a
KafkaItemReader.Autconfiguration for a
KafkaItemReader.Properties to configure a
KafkaItemWriter.Map implementation of the
TaskBatchDao.Stores Task Execution Information to a in-memory map.
Utility class that sends batch job listener payloads to the notification channel.
Forked and simplified version of the
org.springframework.boot.actuate.autoconfigure.metrics.MetricsAutoConfiguration form
spring-boot-actuator
Auto-configuration for Micrometer-based metrics.MySQL implementation of a
PagingQueryProvider using database specific features.A simple no-op implementation of the
EnvironmentVariablesProvider.Oracle implementation of a
PagingQueryProvider using database specific
features.Interface defining the functionality to be provided for generating paging queries.
Returns the
List<String> provided.Postgres implementation of a
PagingQueryProvider using database specific
features.Converter for taking properties of format
start-end or start (where
start and end are both integers) and converting them into Range instances for
configuring a FlatFileItemReader.Returns any command line arguments used with the
TaskExecution provided
appended with any additional arguments configured.Copies all existing environment variables as made available in the
Environment
only if includeCurrentEnvironment is set to true (default).Base
Configuration class providing common structure for enabling and using
Spring Task.TaskExplorer for that gathers task information from a task repository.
Simple implementation of the
TaskNameResolver interface.Records the task execution information to the log and to TaskExecutionDao provided.
When spring.cloud.task.single-instance-enabled is set to true this listener will create
a lock for the task based on the spring.cloud.task.name.
Autoconfiguration to create a single step Spring Batch Job.
Properties to configure the step and job level properties for a single step job.
Autoconfiguration of
SingleInstanceTaskListener.Factory bean for
PagingQueryProvider interface.Utility class that generates the actual SQL statements used by query providers.
Sql Server implementation of a
PagingQueryProvider using database specific
features.Incrementer using SQL Server's sequence.
This is a StepExecution DTO created so that a
StepExecution can be serialized into Json
without having to add mixins to an ObjectMapper.Spring Boot Application that has tasks enabled.
A commandline runner that prints a timestamp.
Provides auto configuration for the
TaskBatchExecutionListener.Auto configuration for
TaskBatchExecutionListener.Maintains the association between a
TaskExecution and a JobExecution
executed within it.Attaches the listeners to the job and its steps.
Responsible for storing the relationship between a Spring Batch job and the Spring
Cloud task it was executed within.
Injects a configured
TaskBatchExecutionListener into any batch jobs (beans
assignable to AbstractJob) that are executed within the scope of a task.FactoryBean for a TaskBatchExecutionListener.Establish properties to be used for how Tasks work with Spring Batch.
Provides a strategy interface for providing configuration customization to the task
system.
Configuration for a
TaskExecutionListener.Base Exception for any Task issues.
Represents the state of the Task for each execution.
Data Access Object for task executions.
A
FactoryBean implementation that creates the appropriate
TaskExecutionDao based on the provided information.Is thrown when executing a task.
The listener interface for receiving task execution events.
A no-op implementation of the
TaskExecutionListener to allow for overriding
only the methods of interest.Offers methods that allow users to query the task executions that are available.
ApplicationRunner to launch Spring Batch jobs.Factory bean for creating an instance of
TaskJobLauncherApplicationRunner.Provides auto configuration for the
TaskJobLauncherApplicationRunner.A sink stream application that launches a tasks.
Request that contains the maven repository and property information required by the
TaskLauncherSink to launch the task.
Configuration for a
TaskLifecycleListener.Monitors the lifecycle of a task.
Identifies all beans that contain a TaskExecutionListener annotation and stores the
associated method so that it can be called by the
TaskExecutionListener at the
appropriate time.Initializes TaskListenerExecutor for a task.
Utility class for publishing Spring Cloud Task specific metrics via Micrometer.
Strategy interface for customizing how the name of a task is determined.
A processor that takes the maven repository coordinates and datasource configuration
for a task and sends a
TaskLaunchRequest message to a task sink.Properties available to configure the task.
TaskRepository interface offers methods that create and update task execution
information.
Utility for initializing the Task Repository's datasource.
Records an entry in the TASK_RUN_OUTPUT table on the BeforeTask event.
Entity for the id and output to be written to the data store.
A task sink sample application for launching tasks.