Module org.elasticsearch.server

Package org.elasticsearch.cluster.routing.allocation.decider

Class WriteLoadConstraintDecider

java.lang.Object

org.elasticsearch.cluster.routing.allocation.decider.AllocationDecider

org.elasticsearch.cluster.routing.allocation.decider.WriteLoadConstraintDecider

public class WriteLoadConstraintDecider
extends AllocationDecider

Decides whether shards can be allocated to cluster nodes, or can remain on cluster nodes, based on the target node's current write thread pool usage stats and any candidate shard's write load estimate.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	NAME

Constructor Summary

Constructors

Constructor	Description
WriteLoadConstraintDecider(ClusterSettings clusterSettings)

Method Summary

Modifier and Type	Method	Description
Decision	canAllocate(ShardRouting shardRouting, RoutingNode node, RoutingAllocation allocation)	Returns a Decision whether the given shard routing can be allocated on the given node.
Decision	canRemain(IndexMetadata indexMetadata, ShardRouting shardRouting, RoutingNode node, RoutingAllocation allocation)	Returns a Decision whether the given shard routing can be remain on the given node.
static double	maxShardWriteLoadProportion(List<ShardId> assignedShardIds, Map<ShardId,Double> shardWriteLoads)
static boolean	maxShardWriteLoadProportionIsHigh(double maxShardWriteLoadProportion, double maxShardWriteLoadThreshold)
static boolean	nodeIsHotspotting(NodeUsageStatsForThreadPools nodeUsageStatsForThreadPools, TimeValue hotspotQueueLatencyThreshold, double hotspotUtilizationThreshold)

Methods inherited from class org.elasticsearch.cluster.routing.allocation.decider.AllocationDecider

canAllocate, canAllocate, canAllocateReplicaWhenThereIsRetentionLease, canForceAllocateDuringReplace, canForceAllocatePrimary, canRebalance, canRebalance, getForcedInitialShardAllocationToNodes, shouldAutoExpandToNode

Methods inherited from class java.lang.Object

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

Field Details

NAME

public static final String NAME

See Also:

• Constant Field Values

Constructor Details

WriteLoadConstraintDecider

public WriteLoadConstraintDecider(ClusterSettings clusterSettings)

Method Details

nodeIsHotspotting

public static boolean nodeIsHotspotting(NodeUsageStatsForThreadPools nodeUsageStatsForThreadPools,
 TimeValue hotspotQueueLatencyThreshold,
 double hotspotUtilizationThreshold)

Returns:

Whether a node is currently hotspotting, given the threshold criteria for queue latency and utilization

maxShardWriteLoadProportion

public static double maxShardWriteLoadProportion(List<ShardId> assignedShardIds,
 Map<ShardId,Double> shardWriteLoads)

maxShardWriteLoadProportionIsHigh

public static boolean maxShardWriteLoadProportionIsHigh(double maxShardWriteLoadProportion,
 double maxShardWriteLoadThreshold)

canAllocate

public Decision canAllocate(ShardRouting shardRouting,
 RoutingNode node,
 RoutingAllocation allocation)

Description copied from class: AllocationDecider

Returns a Decision whether the given shard routing can be allocated on the given node. The default is Decision.ALWAYS.

Overrides:

canAllocate in class AllocationDecider

canRemain

public Decision canRemain(IndexMetadata indexMetadata,
 ShardRouting shardRouting,
 RoutingNode node,
 RoutingAllocation allocation)

Description copied from class: AllocationDecider

Returns a Decision whether the given shard routing can be remain on the given node. The default is Decision.ALWAYS.

Overrides:

canRemain in class AllocationDecider