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

Interface PartitionAssignmentStrategy

All Known Implementing Classes:

FixedNodeCountPartitionAssignmentStrategy, LeastLoadedPartitionAssignmentStrategy, RoundRobinPartitionAssignmentStrategy

public interface PartitionAssignmentStrategy

Maps work units onto the currently live cluster nodes. Implementations receive the live nodes (each carrying its reported load), so load-aware strategies can balance accordingly.

Method Summary

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

Method Details

assignPartitions

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