Package io.github.jchejarla.springbatch.clustering.polling
package io.github.jchejarla.springbatch.clustering.polling
Worker-side task polling and execution.
Each node polls for partitions assigned to it, claims them transactionally, and executes the corresponding Spring Batch step concurrently (up to the per-node limit), recording each partition's completion or failure back to the coordination tables.
-
ClassDescriptionThis class is responsible for polling the database for partition tasks assigned to the current node and executing them.