Class ShardCoordinator.ShardAllocationStrategy$
- java.lang.Object
-
- org.apache.pekko.cluster.sharding.ShardCoordinator.ShardAllocationStrategy$
-
- Enclosing class:
- ShardCoordinator
public static class ShardCoordinator.ShardAllocationStrategy$ extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description static ShardCoordinator.ShardAllocationStrategy$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description ShardAllocationStrategy$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ShardCoordinator.ShardAllocationStrategy
leastShardAllocationStrategy(int absoluteLimit, double relativeLimit)
Scala API:ShardAllocationStrategy
that allocates new shards to theShardRegion
(node) with least number of previously allocated shards.
-
-
-
Field Detail
-
MODULE$
public static final ShardCoordinator.ShardAllocationStrategy$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
leastShardAllocationStrategy
public ShardCoordinator.ShardAllocationStrategy leastShardAllocationStrategy(int absoluteLimit, double relativeLimit)
Scala API:ShardAllocationStrategy
that allocates new shards to theShardRegion
(node) with least number of previously allocated shards.When a node is added to the cluster the shards on the existing nodes will be rebalanced to the new node. The
LeastShardAllocationStrategy
picks shards for rebalancing from theShardRegion
s with most number of previously allocated shards. They will then be allocated to theShardRegion
with least number of previously allocated shards, i.e. new members in the cluster. The amount of shards to rebalance in each round can be limited to make it progress slower since rebalancing too many shards at the same time could result in additional load on the system. For example, causing many Event Sourced entites to be started at the same time.It will not rebalance when there is already an ongoing rebalance in progress.
- Parameters:
absoluteLimit
- the maximum number of shards that will be rebalanced in one rebalance roundrelativeLimit
- fraction (< 1.0) of total number of (known) shards that will be rebalanced in one rebalance round
-
-