Package io.github.jchejarla.springbatch.clustering.partition.impl

Class LeastLoadedPartitionAssignmentStrategy

java.lang.Object

io.github.jchejarla.springbatch.clustering.partition.impl.LeastLoadedPartitionAssignmentStrategy

All Implemented Interfaces:

PartitionAssignmentStrategy

public class LeastLoadedPartitionAssignmentStrategy
extends Object
implements PartitionAssignmentStrategy

A load-aware strategy that assigns each partition to the node with the lowest current load.

Each node's running load is seeded from the live load it reported (the count of partitions it is already executing, tracked in BATCH_NODES), then incremented locally as partitions are assigned within this call. This spreads new work toward the least-busy nodes and accounts for work a node is already doing for other jobs — unlike round-robin, which ignores existing load. Ties are broken by node order for deterministic assignment.

Author:

Janardhan Chejarla

Constructor Summary

Constructors

Constructor	Description
LeastLoadedPartitionAssignmentStrategy()

Method Summary

Modifier and Type	Method	Description
List<PartitionAssignment>	assignPartitions(List<org.springframework.batch.infrastructure.item.ExecutionContext> executionContexts, List<ClusterNode> availableNodes)

Methods inherited from class java.lang.Object

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

Constructor Details

LeastLoadedPartitionAssignmentStrategy

public LeastLoadedPartitionAssignmentStrategy()

Method Details

assignPartitions

public List<PartitionAssignment> assignPartitions(List<org.springframework.batch.infrastructure.item.ExecutionContext> executionContexts,
 List<ClusterNode> availableNodes)

Specified by:

assignPartitions in interface PartitionAssignmentStrategy