Index
All Classes and Interfaces|All Packages|Constant Field Values
A
- ABANDONED - Enum constant in enum class io.github.jchejarla.springbatch.clustering.core.CoordinationStatus
- ACTIVE - Enum constant in enum class io.github.jchejarla.springbatch.clustering.mgmt.NodeStatus
- afterPropertiesSet() - Method in class io.github.jchejarla.springbatch.clustering.autoconfigure.BatchClusterDataSourceScriptDatabaseInitializer
- afterPropertiesSet() - Method in class io.github.jchejarla.springbatch.clustering.autoconfigure.ClusterJobRepositoryValidator
- areAllTasksCompleted(long) - Method in class io.github.jchejarla.springbatch.clustering.partition.ClusterAwarePartitionHandler
- arePartitionsTransferableWhenNodeFailed() - Method in class io.github.jchejarla.springbatch.clustering.api.ClusterAwarePartitioner
-
Abstract method to be implemented by subclasses to specify whether partitions should be transferred to other nodes when a node fails.
- assignedNode() - Method in record class io.github.jchejarla.springbatch.clustering.polling.PartitionAssignmentTask
-
Returns the value of the
assignedNoderecord component. - assignedNode() - Method in record class io.github.jchejarla.springbatch.clustering.query.PartitionView
-
Returns the value of the
assignedNoderecord component. - assignPartitions(List<ExecutionContext>, List<ClusterNode>) - Method in class io.github.jchejarla.springbatch.clustering.partition.impl.FixedNodeCountPartitionAssignmentStrategy
-
Assigns partitions to a fixed number of nodes using a round-robin approach.
- assignPartitions(List<ExecutionContext>, List<ClusterNode>) - Method in class io.github.jchejarla.springbatch.clustering.partition.impl.LeastLoadedPartitionAssignmentStrategy
- assignPartitions(List<ExecutionContext>, List<ClusterNode>) - Method in class io.github.jchejarla.springbatch.clustering.partition.impl.RoundRobinPartitionAssignmentStrategy
-
Assigns partitions to nodes using a round-robin approach.
- assignPartitions(List<ExecutionContext>, List<ClusterNode>) - Method in interface io.github.jchejarla.springbatch.clustering.partition.PartitionAssignmentStrategy
B
- BatchClusterAutoConfiguration - Class in io.github.jchejarla.springbatch.clustering.autoconfigure
- BatchClusterAutoConfiguration() - Constructor for class io.github.jchejarla.springbatch.clustering.autoconfigure.BatchClusterAutoConfiguration
- batchClusterDataSourceScriptDatabaseInitializer(DataSource, BatchClusterProperties) - Method in class io.github.jchejarla.springbatch.clustering.autoconfigure.BatchClusterAutoConfiguration
-
Optionally creates the cluster tables on startup, controlled by
spring.batch.cluster.initialize-schema(seeBatchClusterProperties). - BatchClusterDataSourceScriptDatabaseInitializer - Class in io.github.jchejarla.springbatch.clustering.autoconfigure
-
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. - BatchClusterDataSourceScriptDatabaseInitializer(DataSource, DatabaseInitializationMode, String) - Constructor for class io.github.jchejarla.springbatch.clustering.autoconfigure.BatchClusterDataSourceScriptDatabaseInitializer
- batchClusterHealthIndicator(ClusterNodeManager) - Method in class io.github.jchejarla.springbatch.clustering.autoconfigure.BatchClusterAutoConfiguration
- BatchClusterHealthIndicator - Class in io.github.jchejarla.springbatch.clustering.actuate
-
Spring Boot
HealthIndicatorreporting overall batch-cluster health (such as node liveness) under/actuator/health. - BatchClusterHealthIndicator() - Constructor for class io.github.jchejarla.springbatch.clustering.actuate.BatchClusterHealthIndicator
- batchClusteringInfoContributor(BatchClusterProperties) - Method in class io.github.jchejarla.springbatch.clustering.autoconfigure.BatchClusterAutoConfiguration
- BatchClusteringInfoContributor - Class in io.github.jchejarla.springbatch.clustering.actuate
-
Contributes the active clustering configuration (intervals and thresholds) to the
/actuator/infoendpoint. - BatchClusteringInfoContributor() - Constructor for class io.github.jchejarla.springbatch.clustering.actuate.BatchClusteringInfoContributor
- batchClusterJobsEndpoint(BatchClusterQueryService) - Method in class io.github.jchejarla.springbatch.clustering.autoconfigure.BatchClusterAutoConfiguration
- BatchClusterJobsEndpoint - Class in io.github.jchejarla.springbatch.clustering.actuate
-
Actuator endpoint exposed at
/actuator/batch-cluster-jobsthat 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. - BatchClusterJobsEndpoint() - Constructor for class io.github.jchejarla.springbatch.clustering.actuate.BatchClusterJobsEndpoint
- batchClusterNodeHealthIndicator(ClusterNodeInfo) - Method in class io.github.jchejarla.springbatch.clustering.autoconfigure.BatchClusterAutoConfiguration
- BatchClusterNodeHealthIndicator - Class in io.github.jchejarla.springbatch.clustering.actuate
-
Spring Boot
HealthIndicatorreporting this node's own cluster health — its current status and most recent heartbeat. - BatchClusterNodeHealthIndicator() - Constructor for class io.github.jchejarla.springbatch.clustering.actuate.BatchClusterNodeHealthIndicator
- batchClusterNodesEndpoint(ClusterNodeManager) - Method in class io.github.jchejarla.springbatch.clustering.autoconfigure.BatchClusterAutoConfiguration
- BatchClusterNodesEndpoint - Class in io.github.jchejarla.springbatch.clustering.actuate
-
Actuator endpoint exposed at
/actuator/batch-clusterthat lists the cluster's nodes and, for a given node, its partition assignments and their status. - BatchClusterNodesEndpoint() - Constructor for class io.github.jchejarla.springbatch.clustering.actuate.BatchClusterNodesEndpoint
- BatchClusterProperties - Class in io.github.jchejarla.springbatch.clustering.autoconfigure
-
Configuration for database-coordinated Spring Batch clustering, bound from the
spring.batch.cluster.*namespace. - BatchClusterProperties() - Constructor for class io.github.jchejarla.springbatch.clustering.autoconfigure.BatchClusterProperties
- BatchClusterProperties.HostIdentifier - Enum Class in io.github.jchejarla.springbatch.clustering.autoconfigure
- batchClusterQueryService(JdbcTemplate, DBSpecificQueryProvider) - Method in class io.github.jchejarla.springbatch.clustering.autoconfigure.BatchClusterAutoConfiguration
- BatchClusterQueryService - Class in io.github.jchejarla.springbatch.clustering.query
-
Read-only, job-centric view of the cluster: which node masters a job, how many partitions it has, and where each partition is running.
- BatchClusterQueryService() - Constructor for class io.github.jchejarla.springbatch.clustering.query.BatchClusterQueryService
- buildPartitionStrategy() - Method in class io.github.jchejarla.springbatch.clustering.api.ClusterAwarePartitioner
-
Abstract method to be implemented by subclasses to define the partitioning strategy to be used.
C
- checkForOrphanedTasks(long) - Method in class io.github.jchejarla.springbatch.clustering.core.DatabaseBackedClusterService
- CLAIMED - Enum constant in enum class io.github.jchejarla.springbatch.clustering.partition.PartitionStatus
- claimOrphanedMasterJob(long, String, String, String) - Method in class io.github.jchejarla.springbatch.clustering.core.DatabaseBackedClusterService
-
Atomically claims an orphaned job for recovery: transitions its coordination row to
recoveringStatusand takes ownership (master_node_id = thisNodeId), guarded by the lost owner's node id. - CLUSTER_ENABLED - Static variable in class io.github.jchejarla.springbatch.clustering.autoconfigure.conditions.OnClusterEnabledCondition
- CLUSTER_NODE_IDENTIFIER - Static variable in class io.github.jchejarla.springbatch.clustering.partition.ClusterPartitioningConstants
- ClusterAwareAggregator - Class in io.github.jchejarla.springbatch.clustering.api
-
An extension of Spring Batch's
RemoteStepExecutionAggregatorthat provides custom callbacks for handling the success or failure of partitioned step executions in a clustered environment. - ClusterAwareAggregator(ClusterAwareAggregatorCallback, JobRepository) - Constructor for class io.github.jchejarla.springbatch.clustering.api.ClusterAwareAggregator
-
Constructs a new
ClusterAwareAggregatorwith the specified callback. - ClusterAwareAggregatorCallback - Interface in io.github.jchejarla.springbatch.clustering.api
-
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.
- ClusterAwarePartitioner - Class in io.github.jchejarla.springbatch.clustering.api
-
An abstract Spring Batch
Partitionerthat enables distributed partitioning in a clustered environment. - ClusterAwarePartitioner() - Constructor for class io.github.jchejarla.springbatch.clustering.api.ClusterAwarePartitioner
- clusterAwarePartitionHandler(DatabaseBackedClusterService, BatchClusterProperties) - Method in class io.github.jchejarla.springbatch.clustering.autoconfigure.BatchClusterAutoConfiguration
- ClusterAwarePartitionHandler - Class in io.github.jchejarla.springbatch.clustering.partition
-
A custom
PartitionHandlerthat coordinates partition execution across a dynamic cluster of Spring Batch nodes using a shared relational database for metadata synchronization. - ClusterAwarePartitionHandler() - Constructor for class io.github.jchejarla.springbatch.clustering.partition.ClusterAwarePartitionHandler
- clusteredStepsTasksExecutor(BatchClusterProperties) - Method in class io.github.jchejarla.springbatch.clustering.autoconfigure.BatchClusterAutoConfiguration
- clusterJobRecoveryManager(DatabaseBackedClusterService, BatchClusterProperties, JobExplorer, JobRepository, TaskScheduler) - Method in class io.github.jchejarla.springbatch.clustering.autoconfigure.BatchClusterAutoConfiguration
- ClusterJobRecoveryManager - Class in io.github.jchejarla.springbatch.clustering.mgmt
-
Recovers jobs whose master node has been lost from the cluster.
- ClusterJobRecoveryManager() - Constructor for class io.github.jchejarla.springbatch.clustering.mgmt.ClusterJobRecoveryManager
- clusterJobRepositoryValidator(JobRepository) - Method in class io.github.jchejarla.springbatch.clustering.autoconfigure.BatchClusterAutoConfiguration
-
Fails fast if clustering is enabled on the Spring Batch 6 default (in-memory) JobRepository, which cannot coordinate a cluster.
- ClusterJobRepositoryValidator - Class in io.github.jchejarla.springbatch.clustering.autoconfigure
-
Fails fast at startup when clustering is enabled but the active
JobRepositoryis the in-memoryResourcelessJobRepository— the Spring Batch 6 default. - ClusterJobRepositoryValidator() - Constructor for class io.github.jchejarla.springbatch.clustering.autoconfigure.ClusterJobRepositoryValidator
- clusterMonitoringScheduler() - Method in class io.github.jchejarla.springbatch.clustering.autoconfigure.BatchClusterAutoConfiguration
- ClusterNode - Record Class in io.github.jchejarla.springbatch.clustering.mgmt
- ClusterNode(String, long) - Constructor for record class io.github.jchejarla.springbatch.clustering.mgmt.ClusterNode
-
Creates an instance of a
ClusterNoderecord class. - ClusterNodeHealthCondition - Class in io.github.jchejarla.springbatch.clustering.mgmt
- ClusterNodeHealthCondition() - Constructor for class io.github.jchejarla.springbatch.clustering.mgmt.ClusterNodeHealthCondition
- clusterNodeInfo(BatchClusterProperties) - Method in class io.github.jchejarla.springbatch.clustering.autoconfigure.BatchClusterAutoConfiguration
- ClusterNodeInfo - Class in io.github.jchejarla.springbatch.clustering.mgmt
- ClusterNodeInfo() - Constructor for class io.github.jchejarla.springbatch.clustering.mgmt.ClusterNodeInfo
- clusterNodeManager(DatabaseBackedClusterService, BatchClusterProperties, TaskScheduler, ClusterNodeInfo, ClusterNodeStatusChangeConditionNotifier) - Method in class io.github.jchejarla.springbatch.clustering.autoconfigure.BatchClusterAutoConfiguration
- ClusterNodeManager - Class in io.github.jchejarla.springbatch.clustering.mgmt
- ClusterNodeManager() - Constructor for class io.github.jchejarla.springbatch.clustering.mgmt.ClusterNodeManager
- clusterNodes() - Method in class io.github.jchejarla.springbatch.clustering.actuate.BatchClusterNodesEndpoint
- ClusterNodeStatusChangeConditionNotifier - Interface in io.github.jchejarla.springbatch.clustering.mgmt
- ClusterPartitioningConstants - Class in io.github.jchejarla.springbatch.clustering.partition
- ClusterPartitioningConstants() - Constructor for class io.github.jchejarla.springbatch.clustering.partition.ClusterPartitioningConstants
- COMPLETED - Enum constant in enum class io.github.jchejarla.springbatch.clustering.core.CoordinationStatus
- COMPLETED - Enum constant in enum class io.github.jchejarla.springbatch.clustering.partition.PartitionStatus
- completedTasksCleanupScheduler() - Method in class io.github.jchejarla.springbatch.clustering.autoconfigure.BatchClusterAutoConfiguration
- COMPLETION_DETECTED - Enum constant in enum class io.github.jchejarla.springbatch.clustering.query.JobPhase
- ConditionalOnClusterEnabled - Annotation Interface in io.github.jchejarla.springbatch.clustering.autoconfigure.conditions
- contribute(Info.Builder) - Method in class io.github.jchejarla.springbatch.clustering.actuate.BatchClusteringInfoContributor
- coordinationStatus() - Method in record class io.github.jchejarla.springbatch.clustering.query.JobClusterView
-
Returns the value of the
coordinationStatusrecord component. - coordinationStatus() - Method in record class io.github.jchejarla.springbatch.clustering.query.JobSummaryView
-
Returns the value of the
coordinationStatusrecord component. - CoordinationStatus - Enum Class in io.github.jchejarla.springbatch.clustering.core
-
Lifecycle states of a job-coordination row in
BATCH_JOB_COORDINATION. - CREATED - Enum constant in enum class io.github.jchejarla.springbatch.clustering.core.CoordinationStatus
- createDistributedPartitions(int) - Method in class io.github.jchejarla.springbatch.clustering.api.ClusterAwarePartitioner
-
Abstract method to be implemented by subclasses to define how the input data should be split into chunks for distribution across the cluster nodes.
- currentDbTimestampExpression() - Method in interface io.github.jchejarla.springbatch.clustering.core.DBSpecificQueryProvider
-
The database-clock "now" expression for this dialect.
- currentDbTimestampExpression() - Method in class io.github.jchejarla.springbatch.clustering.core.serviceimpl.DB2DatabaseQueryProvider
- currentDbTimestampExpression() - Method in class io.github.jchejarla.springbatch.clustering.core.serviceimpl.OracleDatabaseQueryProvider
- currentDbTimestampExpression() - Method in class io.github.jchejarla.springbatch.clustering.core.serviceimpl.SQLServerDatabaseQueryProvider
- currentLoad() - Method in record class io.github.jchejarla.springbatch.clustering.mgmt.ClusterNode
-
Returns the value of the
currentLoadrecord component.
D
- databaseBackedClusterService - Variable in class io.github.jchejarla.springbatch.clustering.api.ClusterAwarePartitioner
- databaseBackedClusterService(JdbcTemplate, BatchClusterProperties, DBSpecificQueryProvider) - Method in class io.github.jchejarla.springbatch.clustering.autoconfigure.BatchClusterAutoConfiguration
- DatabaseBackedClusterService - Class in io.github.jchejarla.springbatch.clustering.core
- DatabaseBackedClusterService() - Constructor for class io.github.jchejarla.springbatch.clustering.core.DatabaseBackedClusterService
- DB2DatabaseQueryProvider - Class in io.github.jchejarla.springbatch.clustering.core.serviceimpl
-
Query provider for IBM Db2.
- DB2DatabaseQueryProvider() - Constructor for class io.github.jchejarla.springbatch.clustering.core.serviceimpl.DB2DatabaseQueryProvider
- dbSpecificQueryProvider(DataSource) - Method in class io.github.jchejarla.springbatch.clustering.autoconfigure.BatchClusterAutoConfiguration
- DBSpecificQueryProvider - Interface in io.github.jchejarla.springbatch.clustering.core
- decrementLoadCount() - Method in enum class io.github.jchejarla.springbatch.clustering.mgmt.NodeLoad
- deleteNodesUnreachable() - Method in class io.github.jchejarla.springbatch.clustering.core.DatabaseBackedClusterService
- DISTRIBUTED - Enum constant in enum class io.github.jchejarla.springbatch.clustering.query.JobPhase
- doHandleFailed(Collection<StepExecution>) - Method in class io.github.jchejarla.springbatch.clustering.api.ClusterAwareAggregator
-
Handles the failed case for a collection of step executions.
- doHandleSuccess(Collection<StepExecution>) - Method in class io.github.jchejarla.springbatch.clustering.api.ClusterAwareAggregator
-
Handles the success case for a collection of step executions.
E
- equals(Object) - Method in record class io.github.jchejarla.springbatch.clustering.mgmt.ClusterNode
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class io.github.jchejarla.springbatch.clustering.mgmt.OrphanedMasterJob
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class io.github.jchejarla.springbatch.clustering.partition.PartitionAssignment
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class io.github.jchejarla.springbatch.clustering.polling.PartitionAssignmentTask
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class io.github.jchejarla.springbatch.clustering.query.JobClusterView
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class io.github.jchejarla.springbatch.clustering.query.JobSummaryView
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class io.github.jchejarla.springbatch.clustering.query.PartitionView
-
Indicates whether some other object is "equal to" this one.
- executeStep(PartitionAssignmentTask) - Method in class io.github.jchejarla.springbatch.clustering.polling.PartitionedWorkerNodeTasksRunner
- executionContext() - Method in record class io.github.jchejarla.springbatch.clustering.partition.PartitionAssignment
-
Returns the value of the
executionContextrecord component.
F
- FAILED - Enum constant in enum class io.github.jchejarla.springbatch.clustering.partition.PartitionStatus
- fetchPartitionAssignedTasks() - Method in class io.github.jchejarla.springbatch.clustering.core.DatabaseBackedClusterService
- findOrphanedMasterJobs() - Method in class io.github.jchejarla.springbatch.clustering.core.DatabaseBackedClusterService
-
Returns jobs whose master node has left the cluster (coordination row still
STARTED, master node no longer registered). - FIXED_NODE_COUNT - Enum constant in enum class io.github.jchejarla.springbatch.clustering.partition.PartitioningMode
- FixedNodeCountPartitionAssignmentStrategy - Class in io.github.jchejarla.springbatch.clustering.partition.impl
-
A partition strategy that assigns partitions to a fixed number of nodes.
- FixedNodeCountPartitionAssignmentStrategy() - Constructor for class io.github.jchejarla.springbatch.clustering.partition.impl.FixedNodeCountPartitionAssignmentStrategy
G
- getActiveNodes() - Method in class io.github.jchejarla.springbatch.clustering.core.DatabaseBackedClusterService
- getActiveNodesQuery() - Method in interface io.github.jchejarla.springbatch.clustering.core.DBSpecificQueryProvider
- getAllNodesInClusterQuery() - Method in interface io.github.jchejarla.springbatch.clustering.core.DBSpecificQueryProvider
- getCheckForOrphanedTasksQuery() - Method in interface io.github.jchejarla.springbatch.clustering.core.DBSpecificQueryProvider
- getClaimOrphanedMasterJobQuery() - Method in interface io.github.jchejarla.springbatch.clustering.core.DBSpecificQueryProvider
-
Atomically claims an orphaned coordination row for recovery: sets the transient status and takes ownership (
master_node_id), guarded by the (job execution, lost owner) pair. - getCoordinatedJobsQuery() - Method in interface io.github.jchejarla.springbatch.clustering.core.DBSpecificQueryProvider
-
Read-only: lists coordinated jobs (most recent first), for the job-centric observability view.
- getCurrentLoad() - Method in enum class io.github.jchejarla.springbatch.clustering.mgmt.NodeLoad
- getDeleteNodesUnreachableQuery() - Method in interface io.github.jchejarla.springbatch.clustering.core.DBSpecificQueryProvider
- getDeleteNodesUnreachableQuery() - Method in class io.github.jchejarla.springbatch.clustering.core.serviceimpl.DB2DatabaseQueryProvider
- getDeleteNodesUnreachableQuery() - Method in class io.github.jchejarla.springbatch.clustering.core.serviceimpl.H2DatabaseQueryProvider
- getDeleteNodesUnreachableQuery() - Method in class io.github.jchejarla.springbatch.clustering.core.serviceimpl.MySQLDatabaseQueryProvider
- getDeleteNodesUnreachableQuery() - Method in class io.github.jchejarla.springbatch.clustering.core.serviceimpl.OracleDatabaseQueryProvider
- getDeleteNodesUnreachableQuery() - Method in class io.github.jchejarla.springbatch.clustering.core.serviceimpl.PostgreSQLDatabaseQueryProvider
- getDeleteNodesUnreachableQuery() - Method in class io.github.jchejarla.springbatch.clustering.core.serviceimpl.SQLServerDatabaseQueryProvider
- getFailedTasksCount(long) - Method in class io.github.jchejarla.springbatch.clustering.core.DatabaseBackedClusterService
-
Number of partitions that ended FAILED for this job, used by the master to fail the step.
- getFailedTasksCountQuery() - Method in interface io.github.jchejarla.springbatch.clustering.core.DBSpecificQueryProvider
-
Count of partitions that ended in FAILED for a job, so the master can fail the step accordingly.
- getFetchPartitionAssignedTasksQuery() - Method in interface io.github.jchejarla.springbatch.clustering.core.DBSpecificQueryProvider
- getInsertQueryToRegisterNodeQuery() - Method in interface io.github.jchejarla.springbatch.clustering.core.DBSpecificQueryProvider
- getJobCoordinationByIdQuery() - Method in interface io.github.jchejarla.springbatch.clustering.core.DBSpecificQueryProvider
-
Read-only: the coordination row for one job execution.
- getJobView(long) - Method in class io.github.jchejarla.springbatch.clustering.query.BatchClusterQueryService
-
Returns the job-centric view for one job execution, or empty if it is not (or no longer) coordinated.
- getMarkNodesUnreachableQuery() - Method in interface io.github.jchejarla.springbatch.clustering.core.DBSpecificQueryProvider
- getMarkNodesUnreachableQuery() - Method in class io.github.jchejarla.springbatch.clustering.core.serviceimpl.DB2DatabaseQueryProvider
- getMarkNodesUnreachableQuery() - Method in class io.github.jchejarla.springbatch.clustering.core.serviceimpl.H2DatabaseQueryProvider
- getMarkNodesUnreachableQuery() - Method in class io.github.jchejarla.springbatch.clustering.core.serviceimpl.MySQLDatabaseQueryProvider
- getMarkNodesUnreachableQuery() - Method in class io.github.jchejarla.springbatch.clustering.core.serviceimpl.OracleDatabaseQueryProvider
- getMarkNodesUnreachableQuery() - Method in class io.github.jchejarla.springbatch.clustering.core.serviceimpl.PostgreSQLDatabaseQueryProvider
- getMarkNodesUnreachableQuery() - Method in class io.github.jchejarla.springbatch.clustering.core.serviceimpl.SQLServerDatabaseQueryProvider
- getNodesInCluster() - Method in class io.github.jchejarla.springbatch.clustering.core.DatabaseBackedClusterService
- getOrphanedMasterJobsQuery() - Method in interface io.github.jchejarla.springbatch.clustering.core.DBSpecificQueryProvider
-
Finds jobs whose current owner has left the cluster: coordination rows still in-flight (
STARTED, orRECOVERINGif a previous reaper died) whosemaster_node_idno longer exists inbatch_nodes(the owner was marked unreachable and then removed by the node-cleanup phase). - getPartitionsByMasterStepQuery() - Method in interface io.github.jchejarla.springbatch.clustering.core.DBSpecificQueryProvider
-
Read-only: the partitions of a job (by manager step execution id) with their placement and status.
- getPendingTasksCount(long) - Method in class io.github.jchejarla.springbatch.clustering.core.DatabaseBackedClusterService
- getPendingTasksCountQuery() - Method in interface io.github.jchejarla.springbatch.clustering.core.DBSpecificQueryProvider
- getRecordPhaseEventQuery() - Method in interface io.github.jchejarla.springbatch.clustering.core.DBSpecificQueryProvider
-
Appends a coordination phase event, timestamped with the database clock (single clock across nodes).
- getSaveBatchJobCoordinationInfoQuery() - Method in interface io.github.jchejarla.springbatch.clustering.core.DBSpecificQueryProvider
- getSaveBatchPartitionsQuery() - Method in interface io.github.jchejarla.springbatch.clustering.core.DBSpecificQueryProvider
- getStrategy(PartitionStrategy) - Static method in class io.github.jchejarla.springbatch.clustering.partition.PartitionStrategyFactory
- getTimeStampColumnWithDiffInMillisToCurrentTime(String) - Method in interface io.github.jchejarla.springbatch.clustering.core.DBSpecificQueryProvider
-
Returns a dialect-specific SQL expression for the elapsed milliseconds between
columnNameand the current database time, used in heartbeat-age comparisons. - getTimeStampColumnWithDiffInMillisToCurrentTime(String) - Method in class io.github.jchejarla.springbatch.clustering.core.serviceimpl.DB2DatabaseQueryProvider
- getTimeStampColumnWithDiffInMillisToCurrentTime(String) - Method in class io.github.jchejarla.springbatch.clustering.core.serviceimpl.H2DatabaseQueryProvider
- getTimeStampColumnWithDiffInMillisToCurrentTime(String) - Method in class io.github.jchejarla.springbatch.clustering.core.serviceimpl.MySQLDatabaseQueryProvider
- getTimeStampColumnWithDiffInMillisToCurrentTime(String) - Method in class io.github.jchejarla.springbatch.clustering.core.serviceimpl.OracleDatabaseQueryProvider
- getTimeStampColumnWithDiffInMillisToCurrentTime(String) - Method in class io.github.jchejarla.springbatch.clustering.core.serviceimpl.PostgreSQLDatabaseQueryProvider
- getTimeStampColumnWithDiffInMillisToCurrentTime(String) - Method in class io.github.jchejarla.springbatch.clustering.core.serviceimpl.SQLServerDatabaseQueryProvider
- getUpdateBatchJobCoordinationStatusQuery() - Method in interface io.github.jchejarla.springbatch.clustering.core.DBSpecificQueryProvider
- getUpdateBatchPartitionsToReAssignedNodesQuery() - Method in interface io.github.jchejarla.springbatch.clustering.core.DBSpecificQueryProvider
- getUpdateLastUpdateTimeQuery() - Method in interface io.github.jchejarla.springbatch.clustering.core.DBSpecificQueryProvider
- getUpdateNodeHeartBeatQuery() - Method in interface io.github.jchejarla.springbatch.clustering.core.DBSpecificQueryProvider
- getUpdatePartitionStatusToQuery() - Method in interface io.github.jchejarla.springbatch.clustering.core.DBSpecificQueryProvider
H
- H2DatabaseQueryProvider - Class in io.github.jchejarla.springbatch.clustering.core.serviceimpl
- H2DatabaseQueryProvider() - Constructor for class io.github.jchejarla.springbatch.clustering.core.serviceimpl.H2DatabaseQueryProvider
- handle(StepExecutionSplitter, StepExecution) - Method in class io.github.jchejarla.springbatch.clustering.partition.ClusterAwarePartitionHandler
-
Handles the splitting and coordination of partitioned steps across the cluster.
- hashCode() - Method in record class io.github.jchejarla.springbatch.clustering.mgmt.ClusterNode
-
Returns a hash code value for this object.
- hashCode() - Method in record class io.github.jchejarla.springbatch.clustering.mgmt.OrphanedMasterJob
-
Returns a hash code value for this object.
- hashCode() - Method in record class io.github.jchejarla.springbatch.clustering.partition.PartitionAssignment
-
Returns a hash code value for this object.
- hashCode() - Method in record class io.github.jchejarla.springbatch.clustering.polling.PartitionAssignmentTask
-
Returns a hash code value for this object.
- hashCode() - Method in record class io.github.jchejarla.springbatch.clustering.query.JobClusterView
-
Returns a hash code value for this object.
- hashCode() - Method in record class io.github.jchejarla.springbatch.clustering.query.JobSummaryView
-
Returns a hash code value for this object.
- hashCode() - Method in record class io.github.jchejarla.springbatch.clustering.query.PartitionView
-
Returns a hash code value for this object.
- health() - Method in class io.github.jchejarla.springbatch.clustering.actuate.BatchClusterHealthIndicator
- health() - Method in class io.github.jchejarla.springbatch.clustering.actuate.BatchClusterNodeHealthIndicator
- HOST_NAME - Enum constant in enum class io.github.jchejarla.springbatch.clustering.autoconfigure.BatchClusterProperties.HostIdentifier
I
- incrementLoadCount() - Method in enum class io.github.jchejarla.springbatch.clustering.mgmt.NodeLoad
- INST - Enum constant in enum class io.github.jchejarla.springbatch.clustering.mgmt.NodeLoad
- io.github.jchejarla.springbatch.clustering.actuate - package io.github.jchejarla.springbatch.clustering.actuate
-
Spring Boot Actuator integration for observability of the batch cluster.
- io.github.jchejarla.springbatch.clustering.api - package io.github.jchejarla.springbatch.clustering.api
-
User-facing extension points for building cluster-aware partitioned jobs.
- io.github.jchejarla.springbatch.clustering.autoconfigure - package io.github.jchejarla.springbatch.clustering.autoconfigure
-
Spring Boot auto-configuration and the configuration-property surface for clustering.
- io.github.jchejarla.springbatch.clustering.autoconfigure.conditions - package io.github.jchejarla.springbatch.clustering.autoconfigure.conditions
-
Spring
@Conditionalsupport that enables the cluster components only when clustering is turned on (thespring.batch.cluster.enabledproperty). - io.github.jchejarla.springbatch.clustering.core - package io.github.jchejarla.springbatch.clustering.core
-
The database-backed coordination core.
- io.github.jchejarla.springbatch.clustering.core.serviceimpl - package io.github.jchejarla.springbatch.clustering.core.serviceimpl
-
Per-database
DBSpecificQueryProviderimplementations. - io.github.jchejarla.springbatch.clustering.mgmt - package io.github.jchejarla.springbatch.clustering.mgmt
-
Cluster membership and lifecycle management.
- io.github.jchejarla.springbatch.clustering.partition - package io.github.jchejarla.springbatch.clustering.partition
-
Master-side partitioning.
- io.github.jchejarla.springbatch.clustering.partition.impl - package io.github.jchejarla.springbatch.clustering.partition.impl
-
Built-in partition-assignment strategies: round-robin, fixed-node-count, and least-loaded.
- io.github.jchejarla.springbatch.clustering.polling - package io.github.jchejarla.springbatch.clustering.polling
-
Worker-side task polling and execution.
- io.github.jchejarla.springbatch.clustering.query - package io.github.jchejarla.springbatch.clustering.query
-
Read-only, job-centric observability of the cluster.
- IP_ADDRESS - Enum constant in enum class io.github.jchejarla.springbatch.clustering.autoconfigure.BatchClusterProperties.HostIdentifier
- IS_TRANSFERABLE - Static variable in class io.github.jchejarla.springbatch.clustering.partition.ClusterPartitioningConstants
- IS_TRANSFERABLE_IDENTIFIER - Static variable in class io.github.jchejarla.springbatch.clustering.partition.ClusterPartitioningConstants
- isTransferable() - Method in record class io.github.jchejarla.springbatch.clustering.polling.PartitionAssignmentTask
-
Returns the value of the
isTransferablerecord component.
J
- job(String) - Method in class io.github.jchejarla.springbatch.clustering.actuate.BatchClusterJobsEndpoint
- JobClusterView - Record Class in io.github.jchejarla.springbatch.clustering.query
-
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.
- JobClusterView(long, String, String, int, Map<String, Long>, List<PartitionView>) - Constructor for record class io.github.jchejarla.springbatch.clustering.query.JobClusterView
-
Creates an instance of a
JobClusterViewrecord class. - jobExecutionId() - Method in record class io.github.jchejarla.springbatch.clustering.mgmt.OrphanedMasterJob
-
Returns the value of the
jobExecutionIdrecord component. - jobExecutionId() - Method in record class io.github.jchejarla.springbatch.clustering.polling.PartitionAssignmentTask
-
Returns the value of the
jobExecutionIdrecord component. - jobExecutionId() - Method in record class io.github.jchejarla.springbatch.clustering.query.JobClusterView
-
Returns the value of the
jobExecutionIdrecord component. - jobExecutionId() - Method in record class io.github.jchejarla.springbatch.clustering.query.JobSummaryView
-
Returns the value of the
jobExecutionIdrecord component. - JobPhase - Enum Class in io.github.jchejarla.springbatch.clustering.query
-
Master-side coordination phases recorded (when enabled) to
BATCH_JOB_PHASE_EVENTS. - jobs() - Method in class io.github.jchejarla.springbatch.clustering.actuate.BatchClusterJobsEndpoint
- JobSummaryView - Record Class in io.github.jchejarla.springbatch.clustering.query
-
A one-line summary of a coordinated job, for listing.
- JobSummaryView(long, String, String, String) - Constructor for record class io.github.jchejarla.springbatch.clustering.query.JobSummaryView
-
Creates an instance of a
JobSummaryViewrecord class.
L
- LEAST_LOADED - Enum constant in enum class io.github.jchejarla.springbatch.clustering.partition.PartitioningMode
- LeastLoadedPartitionAssignmentStrategy - Class in io.github.jchejarla.springbatch.clustering.partition.impl
-
A load-aware strategy that assigns each partition to the node with the lowest current load.
- LeastLoadedPartitionAssignmentStrategy() - Constructor for class io.github.jchejarla.springbatch.clustering.partition.impl.LeastLoadedPartitionAssignmentStrategy
- listCoordinatedJobs() - Method in class io.github.jchejarla.springbatch.clustering.query.BatchClusterQueryService
-
Lists coordinated jobs, most recent first.
M
- markNodesUnreachable() - Method in class io.github.jchejarla.springbatch.clustering.core.DatabaseBackedClusterService
- markNodesUnreachable() - Method in class io.github.jchejarla.springbatch.clustering.mgmt.ClusterNodeManager
- masterNode() - Method in record class io.github.jchejarla.springbatch.clustering.query.JobClusterView
-
Returns the value of the
masterNoderecord component. - masterNode() - Method in record class io.github.jchejarla.springbatch.clustering.query.JobSummaryView
-
Returns the value of the
masterNoderecord component. - masterNodeId() - Method in record class io.github.jchejarla.springbatch.clustering.mgmt.OrphanedMasterJob
-
Returns the value of the
masterNodeIdrecord component. - masterStepExecutionId() - Method in record class io.github.jchejarla.springbatch.clustering.mgmt.OrphanedMasterJob
-
Returns the value of the
masterStepExecutionIdrecord component. - masterStepExecutionId() - Method in record class io.github.jchejarla.springbatch.clustering.polling.PartitionAssignmentTask
-
Returns the value of the
masterStepExecutionIdrecord component. - masterStepName() - Method in record class io.github.jchejarla.springbatch.clustering.mgmt.OrphanedMasterJob
-
Returns the value of the
masterStepNamerecord component. - masterStepName() - Method in record class io.github.jchejarla.springbatch.clustering.polling.PartitionAssignmentTask
-
Returns the value of the
masterStepNamerecord component. - masterStepName() - Method in record class io.github.jchejarla.springbatch.clustering.query.JobSummaryView
-
Returns the value of the
masterStepNamerecord component. - matches(ConditionContext, AnnotatedTypeMetadata) - Method in class io.github.jchejarla.springbatch.clustering.autoconfigure.conditions.OnClusterEnabledCondition
- MySQLDatabaseQueryProvider - Class in io.github.jchejarla.springbatch.clustering.core.serviceimpl
- MySQLDatabaseQueryProvider() - Constructor for class io.github.jchejarla.springbatch.clustering.core.serviceimpl.MySQLDatabaseQueryProvider
N
- NO - Enum constant in enum class io.github.jchejarla.springbatch.clustering.partition.PartitionTransferableProp
- nodeDetails(String) - Method in class io.github.jchejarla.springbatch.clustering.actuate.BatchClusterNodesEndpoint
- nodeId() - Method in record class io.github.jchejarla.springbatch.clustering.mgmt.ClusterNode
-
Returns the value of the
nodeIdrecord component. - nodeId() - Method in record class io.github.jchejarla.springbatch.clustering.partition.PartitionAssignment
-
Returns the value of the
nodeIdrecord component. - NodeLoad - Enum Class in io.github.jchejarla.springbatch.clustering.mgmt
- NodeStatus - Enum Class in io.github.jchejarla.springbatch.clustering.mgmt
O
- OnClusterEnabledCondition - Class in io.github.jchejarla.springbatch.clustering.autoconfigure.conditions
- OnClusterEnabledCondition() - Constructor for class io.github.jchejarla.springbatch.clustering.autoconfigure.conditions.OnClusterEnabledCondition
- onClusterNodeHeartbeatFail() - Method in interface io.github.jchejarla.springbatch.clustering.mgmt.ClusterNodeStatusChangeConditionNotifier
- onClusterNodeHeartbeatFail() - Method in class io.github.jchejarla.springbatch.clustering.polling.PartitionedWorkerNodeTasksRunner
- onFailure(Collection<StepExecution>) - Method in interface io.github.jchejarla.springbatch.clustering.api.ClusterAwareAggregatorCallback
-
Called when at least one of the partitioned step executions has failed.
- onSuccess(Collection<StepExecution>) - Method in interface io.github.jchejarla.springbatch.clustering.api.ClusterAwareAggregatorCallback
-
Called when all partitioned step executions have completed successfully.
- OracleDatabaseQueryProvider - Class in io.github.jchejarla.springbatch.clustering.core.serviceimpl
- OracleDatabaseQueryProvider() - Constructor for class io.github.jchejarla.springbatch.clustering.core.serviceimpl.OracleDatabaseQueryProvider
- OrphanedMasterJob - Record Class in io.github.jchejarla.springbatch.clustering.mgmt
-
A job whose master node has left the cluster while the job was still running.
- OrphanedMasterJob(long, String, long, String) - Constructor for record class io.github.jchejarla.springbatch.clustering.mgmt.OrphanedMasterJob
-
Creates an instance of a
OrphanedMasterJobrecord class.
P
- partition(int) - Method in class io.github.jchejarla.springbatch.clustering.api.ClusterAwarePartitioner
-
Partitions the input data into chunks and assigns them to available nodes in the cluster.
- PartitionAssignment - Record Class in io.github.jchejarla.springbatch.clustering.partition
- PartitionAssignment(int, ExecutionContext, String) - Constructor for record class io.github.jchejarla.springbatch.clustering.partition.PartitionAssignment
-
Creates an instance of a
PartitionAssignmentrecord class. - PartitionAssignmentStrategy - Interface in io.github.jchejarla.springbatch.clustering.partition
-
Maps work units onto the currently live cluster nodes.
- PartitionAssignmentTask - Record Class in io.github.jchejarla.springbatch.clustering.polling
- PartitionAssignmentTask(Long, String, Long, Long, boolean, String, String) - Constructor for record class io.github.jchejarla.springbatch.clustering.polling.PartitionAssignmentTask
-
Creates an instance of a
PartitionAssignmentTaskrecord class. - partitionCount() - Method in record class io.github.jchejarla.springbatch.clustering.query.JobClusterView
-
Returns the value of the
partitionCountrecord component. - PARTITIONED - Enum constant in enum class io.github.jchejarla.springbatch.clustering.query.JobPhase
- PartitionedWorkerNodeTasksRunner - Class in io.github.jchejarla.springbatch.clustering.polling
-
This class is responsible for polling the database for partition tasks assigned to the current node and executing them.
- PartitionedWorkerNodeTasksRunner() - Constructor for class io.github.jchejarla.springbatch.clustering.polling.PartitionedWorkerNodeTasksRunner
- PartitioningMode - Enum Class in io.github.jchejarla.springbatch.clustering.partition
- partitionKey() - Method in record class io.github.jchejarla.springbatch.clustering.query.PartitionView
-
Returns the value of the
partitionKeyrecord component. - partitionPollingScheduler() - Method in class io.github.jchejarla.springbatch.clustering.autoconfigure.BatchClusterAutoConfiguration
- partitions() - Method in record class io.github.jchejarla.springbatch.clustering.query.JobClusterView
-
Returns the value of the
partitionsrecord component. - PartitionStatus - Enum Class in io.github.jchejarla.springbatch.clustering.partition
-
Lifecycle states of a single partition row in
BATCH_PARTITIONS. - PartitionStrategy - Class in io.github.jchejarla.springbatch.clustering.api
-
A builder class for configuring the partitioning strategy in a Spring Batch clustered environment.
- PartitionStrategy() - Constructor for class io.github.jchejarla.springbatch.clustering.api.PartitionStrategy
- PartitionStrategyFactory - Class in io.github.jchejarla.springbatch.clustering.partition
- PartitionStrategyFactory() - Constructor for class io.github.jchejarla.springbatch.clustering.partition.PartitionStrategyFactory
- PartitionTransferableProp - Enum Class in io.github.jchejarla.springbatch.clustering.partition
- PartitionView - Record Class in io.github.jchejarla.springbatch.clustering.query
-
Read-only view of a single partition's placement and status within a job.
- PartitionView(long, String, String, String) - Constructor for record class io.github.jchejarla.springbatch.clustering.query.PartitionView
-
Creates an instance of a
PartitionViewrecord class. - partitionWorkerTasksRunner(ApplicationContext, JobExplorer, JobRepository, TaskExecutor, BatchClusterProperties, DatabaseBackedClusterService, TaskScheduler, TaskScheduler, TaskScheduler, ClusterNodeInfo) - Method in class io.github.jchejarla.springbatch.clustering.autoconfigure.BatchClusterAutoConfiguration
- PENDING - Enum constant in enum class io.github.jchejarla.springbatch.clustering.partition.PartitionStatus
- pollAndExecute() - Method in class io.github.jchejarla.springbatch.clustering.polling.PartitionedWorkerNodeTasksRunner
-
Polls the database for partition tasks assigned to this node, claims them, and executes them.
- pollForOrphanedTasksAndReArrange(long) - Method in class io.github.jchejarla.springbatch.clustering.partition.ClusterAwarePartitionHandler
- PostgreSQLDatabaseQueryProvider - Class in io.github.jchejarla.springbatch.clustering.core.serviceimpl
- PostgreSQLDatabaseQueryProvider() - Constructor for class io.github.jchejarla.springbatch.clustering.core.serviceimpl.PostgreSQLDatabaseQueryProvider
R
- reapOrphanedMasterJobs() - Method in class io.github.jchejarla.springbatch.clustering.mgmt.ClusterJobRecoveryManager
-
Scans for jobs whose master node has left the cluster and abandons each one (once), so the stranded execution stops hanging and becomes restartable.
- RECEIVED - Enum constant in enum class io.github.jchejarla.springbatch.clustering.query.JobPhase
- recordPhaseEvent(long, String) - Method in class io.github.jchejarla.springbatch.clustering.core.DatabaseBackedClusterService
-
Appends a coordination phase event (for observability), timestamped with the database clock.
- RECOVERING - Enum constant in enum class io.github.jchejarla.springbatch.clustering.core.CoordinationStatus
- registerNode() - Method in class io.github.jchejarla.springbatch.clustering.core.DatabaseBackedClusterService
- removeNodesUnreachable() - Method in class io.github.jchejarla.springbatch.clustering.mgmt.ClusterNodeManager
- ROUND_ROBIN - Enum constant in enum class io.github.jchejarla.springbatch.clustering.partition.PartitioningMode
- RoundRobinPartitionAssignmentStrategy - Class in io.github.jchejarla.springbatch.clustering.partition.impl
-
A partition strategy that assigns partitions to nodes in a round-robin fashion.
- RoundRobinPartitionAssignmentStrategy() - Constructor for class io.github.jchejarla.springbatch.clustering.partition.impl.RoundRobinPartitionAssignmentStrategy
S
- saveBatchJobCoordinationInfo(long, long, String) - Method in class io.github.jchejarla.springbatch.clustering.core.DatabaseBackedClusterService
- saveBatchPartitions(List<Object[]>) - Method in class io.github.jchejarla.springbatch.clustering.core.DatabaseBackedClusterService
- SQLServerDatabaseQueryProvider - Class in io.github.jchejarla.springbatch.clustering.core.serviceimpl
-
Query provider for Microsoft SQL Server.
- SQLServerDatabaseQueryProvider() - Constructor for class io.github.jchejarla.springbatch.clustering.core.serviceimpl.SQLServerDatabaseQueryProvider
- start() - Method in class io.github.jchejarla.springbatch.clustering.mgmt.ClusterJobRecoveryManager
- start() - Method in class io.github.jchejarla.springbatch.clustering.mgmt.ClusterNodeManager
- start() - Method in class io.github.jchejarla.springbatch.clustering.polling.PartitionedWorkerNodeTasksRunner
-
Starts the partition task polling and execution process when the application is ready.
- STARTED - Enum constant in enum class io.github.jchejarla.springbatch.clustering.core.CoordinationStatus
- status() - Method in record class io.github.jchejarla.springbatch.clustering.query.PartitionView
-
Returns the value of the
statusrecord component. - statusCounts() - Method in record class io.github.jchejarla.springbatch.clustering.query.JobClusterView
-
Returns the value of the
statusCountsrecord component. - stepExecutionId() - Method in record class io.github.jchejarla.springbatch.clustering.polling.PartitionAssignmentTask
-
Returns the value of the
stepExecutionIdrecord component. - stepExecutionId() - Method in record class io.github.jchejarla.springbatch.clustering.query.PartitionView
-
Returns the value of the
stepExecutionIdrecord component. - stepName() - Method in record class io.github.jchejarla.springbatch.clustering.polling.PartitionAssignmentTask
-
Returns the value of the
stepNamerecord component.
T
- toString() - Method in record class io.github.jchejarla.springbatch.clustering.mgmt.ClusterNode
-
Returns a string representation of this record class.
- toString() - Method in record class io.github.jchejarla.springbatch.clustering.mgmt.OrphanedMasterJob
-
Returns a string representation of this record class.
- toString() - Method in record class io.github.jchejarla.springbatch.clustering.partition.PartitionAssignment
-
Returns a string representation of this record class.
- toString() - Method in record class io.github.jchejarla.springbatch.clustering.polling.PartitionAssignmentTask
-
Returns a string representation of this record class.
- toString() - Method in record class io.github.jchejarla.springbatch.clustering.query.JobClusterView
-
Returns a string representation of this record class.
- toString() - Method in record class io.github.jchejarla.springbatch.clustering.query.JobSummaryView
-
Returns a string representation of this record class.
- toString() - Method in record class io.github.jchejarla.springbatch.clustering.query.PartitionView
-
Returns a string representation of this record class.
U
- uniqueChunkId() - Method in record class io.github.jchejarla.springbatch.clustering.partition.PartitionAssignment
-
Returns the value of the
uniqueChunkIdrecord component. - UNREACHABLE - Enum constant in enum class io.github.jchejarla.springbatch.clustering.mgmt.NodeStatus
- updateBatchJobCoordinationStatus(long, long, String) - Method in class io.github.jchejarla.springbatch.clustering.core.DatabaseBackedClusterService
- updateBatchPartitionsScheduler() - Method in class io.github.jchejarla.springbatch.clustering.autoconfigure.BatchClusterAutoConfiguration
- updateBatchPartitionsToReAssignedNodes(List<Object[]>) - Method in class io.github.jchejarla.springbatch.clustering.core.DatabaseBackedClusterService
- updateCurrentActiveNodes() - Method in class io.github.jchejarla.springbatch.clustering.mgmt.ClusterNodeManager
- updateHeartbeat() - Method in class io.github.jchejarla.springbatch.clustering.mgmt.ClusterNodeManager
- updateNodeHeartbeat() - Method in class io.github.jchejarla.springbatch.clustering.core.DatabaseBackedClusterService
- updatePartitionsLastUpdatedTime(Collection<PartitionAssignmentTask>) - Method in class io.github.jchejarla.springbatch.clustering.core.DatabaseBackedClusterService
- updatePartitionsStatus(Collection<PartitionAssignmentTask>, String) - Method in class io.github.jchejarla.springbatch.clustering.core.DatabaseBackedClusterService
- updatePartitionStatus(PartitionAssignmentTask, String) - Method in class io.github.jchejarla.springbatch.clustering.core.DatabaseBackedClusterService
V
- valueOf(String) - Static method in enum class io.github.jchejarla.springbatch.clustering.autoconfigure.BatchClusterProperties.HostIdentifier
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class io.github.jchejarla.springbatch.clustering.core.CoordinationStatus
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class io.github.jchejarla.springbatch.clustering.mgmt.NodeLoad
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class io.github.jchejarla.springbatch.clustering.mgmt.NodeStatus
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class io.github.jchejarla.springbatch.clustering.partition.PartitioningMode
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class io.github.jchejarla.springbatch.clustering.partition.PartitionStatus
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class io.github.jchejarla.springbatch.clustering.partition.PartitionTransferableProp
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class io.github.jchejarla.springbatch.clustering.query.JobPhase
-
Returns the enum constant of this class with the specified name.
- values() - Static method in enum class io.github.jchejarla.springbatch.clustering.autoconfigure.BatchClusterProperties.HostIdentifier
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class io.github.jchejarla.springbatch.clustering.core.CoordinationStatus
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class io.github.jchejarla.springbatch.clustering.mgmt.NodeLoad
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class io.github.jchejarla.springbatch.clustering.mgmt.NodeStatus
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class io.github.jchejarla.springbatch.clustering.partition.PartitioningMode
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class io.github.jchejarla.springbatch.clustering.partition.PartitionStatus
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class io.github.jchejarla.springbatch.clustering.partition.PartitionTransferableProp
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class io.github.jchejarla.springbatch.clustering.query.JobPhase
-
Returns an array containing the constants of this enum class, in the order they are declared.
Y
- YES - Enum constant in enum class io.github.jchejarla.springbatch.clustering.partition.PartitionTransferableProp
All Classes and Interfaces|All Packages|Constant Field Values