Package io.github.jchejarla.springbatch.clustering.query

Class BatchClusterQueryService

java.lang.Object

io.github.jchejarla.springbatch.clustering.query.BatchClusterQueryService

public class BatchClusterQueryService
extends Object

Read-only, job-centric view of the cluster: which node masters a job, how many partitions it has, and where each partition is running. This complements the node-centric actuator endpoint.

Purely a set of SELECTs over the coordination tables — it never mutates state and is kept off the hot coordination path. Applications can call it directly to build their own UI/API; the actuator job endpoint is a thin wrapper over it.

Author:

Janardhan Chejarla

Constructor Summary

Constructors

Constructor	Description
BatchClusterQueryService()

Method Summary

Modifier and Type	Method	Description
Optional<JobClusterView>	getJobView(long jobExecutionId)	Returns the job-centric view for one job execution, or empty if it is not (or no longer) coordinated.
List<JobSummaryView>	listCoordinatedJobs()	Lists coordinated jobs, most recent first.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BatchClusterQueryService

public BatchClusterQueryService()

Method Details

listCoordinatedJobs

public List<JobSummaryView> listCoordinatedJobs()

Lists coordinated jobs, most recent first.

getJobView

public Optional<JobClusterView> getJobView(long jobExecutionId)

Returns the job-centric view for one job execution, or empty if it is not (or no longer) coordinated.