All Classes and Interfaces
Class
Description
Optionally creates the cluster coordination tables (
BATCH_NODES,
BATCH_JOB_COORDINATION, BATCH_PARTITIONS, BATCH_JOB_PHASE_EVENTS) on startup,
mirroring Spring Batch's own schema initialization.Spring Boot
HealthIndicator reporting overall batch-cluster health (such as node liveness)
under /actuator/health.Contributes the active clustering configuration (intervals and thresholds) to the
/actuator/info endpoint.Actuator endpoint exposed at
/actuator/batch-cluster-jobs that lists coordinated jobs, and at
/actuator/batch-cluster-jobs/{jobExecutionId} the job-centric view (master node, partition count,
status histogram, and per-partition placement) for one job.Spring Boot
HealthIndicator reporting this node's own cluster health — its current status
and most recent heartbeat.Actuator endpoint exposed at
/actuator/batch-cluster that lists the cluster's nodes and,
for a given node, its partition assignments and their status.Configuration for database-coordinated Spring Batch clustering, bound from the
spring.batch.cluster.* namespace.Read-only, job-centric view of the cluster: which node masters a job, how many partitions it has, and
where each partition is running.
An extension of Spring Batch's
RemoteStepExecutionAggregator that provides
custom callbacks for handling the success or failure of partitioned step executions
in a clustered environment.A callback interface to be implemented by classes that need to react to the
successful completion or failure of a collection of Spring Batch partitioned
step executions in a clustered environment.
An abstract Spring Batch
Partitioner that enables distributed partitioning
in a clustered environment.A custom
PartitionHandler that coordinates partition execution across a dynamic cluster
of Spring Batch nodes using a shared relational database for metadata synchronization.Recovers jobs whose master node has been lost from the cluster.
Fails fast at startup when clustering is enabled but the active
JobRepository is the in-memory
ResourcelessJobRepository — the Spring Batch 6 default.Lifecycle states of a job-coordination row in
BATCH_JOB_COORDINATION.Query provider for IBM Db2.
A partition strategy that assigns partitions to a fixed number of nodes.
A read-only, job-centric view of how a job is distributed across the cluster: which node masters it,
how many partitions it has, the count of partitions in each status, and where each partition is running.
Master-side coordination phases recorded (when enabled) to
BATCH_JOB_PHASE_EVENTS.A one-line summary of a coordinated job, for listing.
A load-aware strategy that assigns each partition to the node with the lowest current load.
A job whose master node has left the cluster while the job was still running.
Maps work units onto the currently live cluster nodes.
This class is responsible for polling the database for partition tasks assigned to the current node
and executing them.
Lifecycle states of a single partition row in
BATCH_PARTITIONS.A builder class for configuring the partitioning strategy in a Spring Batch
clustered environment.
Read-only view of a single partition's placement and status within a job.
A partition strategy that assigns partitions to nodes in a round-robin fashion.
Query provider for Microsoft SQL Server.