org.apache.druid.server.coordinator

Class DiskNormalizedCostBalancerStrategy

java.lang.Object

org.apache.druid.server.coordinator.CostBalancerStrategy

org.apache.druid.server.coordinator.DiskNormalizedCostBalancerStrategy

All Implemented Interfaces:

BalancerStrategy

public class DiskNormalizedCostBalancerStrategy
extends CostBalancerStrategy

Constructor Summary

Constructors

Constructor and Description
DiskNormalizedCostBalancerStrategy(com.google.common.util.concurrent.ListeningExecutorService exec)

Method Summary

Modifier and Type	Method and Description
protected double	computeCost(org.apache.druid.timeline.DataSegment proposalSegment, ServerHolder server, boolean includeCurrentServer) Averages the cost obtained from CostBalancerStrategy.

Methods inherited from class org.apache.druid.server.coordinator.CostBalancerStrategy

calculateInitialTotalCost, calculateNormalization, chooseBestServer, computeJointSegmentsCost, emitStats, findNewSegmentHomeBalancer, findNewSegmentHomeReplicator, intervalCost, pickSegmentToMove, pickServersToDrop

Methods inherited from class java.lang.Object

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

Constructor Detail

DiskNormalizedCostBalancerStrategy

public DiskNormalizedCostBalancerStrategy(com.google.common.util.concurrent.ListeningExecutorService exec)

Method Detail

computeCost

protected double computeCost(org.apache.druid.timeline.DataSegment proposalSegment,
                             ServerHolder server,
                             boolean includeCurrentServer)

Averages the cost obtained from CostBalancerStrategy. Also the costs are weighted according to their usage ratios. This ensures that all the hosts will have the same % disk utilization.

Overrides:

computeCost in class CostBalancerStrategy