| Package | Description | 
|---|---|
| io.druid.server.coordinator | |
| io.druid.server.coordinator.helper | 
| Modifier and Type | Method and Description | 
|---|---|
ServerHolder | 
RandomBalancerStrategy.findNewSegmentHomeBalancer(io.druid.timeline.DataSegment proposalSegment,
                          List<ServerHolder> serverHolders)  | 
ServerHolder | 
CostBalancerStrategy.findNewSegmentHomeBalancer(io.druid.timeline.DataSegment proposalSegment,
                          List<ServerHolder> serverHolders)  | 
ServerHolder | 
BalancerStrategy.findNewSegmentHomeBalancer(io.druid.timeline.DataSegment proposalSegment,
                          List<ServerHolder> serverHolders)  | 
ServerHolder | 
RandomBalancerStrategy.findNewSegmentHomeReplicator(io.druid.timeline.DataSegment proposalSegment,
                            List<ServerHolder> serverHolders)  | 
ServerHolder | 
CostBalancerStrategy.findNewSegmentHomeReplicator(io.druid.timeline.DataSegment proposalSegment,
                            List<ServerHolder> serverHolders)  | 
ServerHolder | 
BalancerStrategy.findNewSegmentHomeReplicator(io.druid.timeline.DataSegment proposalSegment,
                            List<ServerHolder> serverHolders)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected com.metamx.common.Pair<Double,ServerHolder> | 
CostBalancerStrategy.chooseBestServer(io.druid.timeline.DataSegment proposalSegment,
                Iterable<ServerHolder> serverHolders,
                boolean includeCurrentServer)
For assignment, we want to move to the lowest cost server that isn't already serving the segment. 
 | 
com.google.common.collect.MinMaxPriorityQueue<ServerHolder> | 
DruidCluster.get(String tier)  | 
Map<String,com.google.common.collect.MinMaxPriorityQueue<ServerHolder>> | 
DruidCluster.getCluster()  | 
com.google.common.collect.MinMaxPriorityQueue<ServerHolder> | 
DruidCluster.getServersByTier(String tier)  | 
Iterable<com.google.common.collect.MinMaxPriorityQueue<ServerHolder>> | 
DruidCluster.getSortedServersByTier()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
DruidCluster.add(ServerHolder serverHolder)  | 
int | 
ServerHolder.compareTo(ServerHolder serverHolder)  | 
protected double | 
CostBalancerStrategy.computeCost(io.druid.timeline.DataSegment proposalSegment,
           ServerHolder server,
           boolean includeCurrentServer)  | 
| Modifier and Type | Method and Description | 
|---|---|
double | 
CostBalancerStrategy.calculateInitialTotalCost(List<ServerHolder> serverHolders)
Calculates the initial cost of the Druid segment configuration. 
 | 
double | 
CostBalancerStrategy.calculateNormalization(List<ServerHolder> serverHolders)
Calculates the cost normalization. 
 | 
protected com.metamx.common.Pair<Double,ServerHolder> | 
CostBalancerStrategy.chooseBestServer(io.druid.timeline.DataSegment proposalSegment,
                Iterable<ServerHolder> serverHolders,
                boolean includeCurrentServer)
For assignment, we want to move to the lowest cost server that isn't already serving the segment. 
 | 
void | 
RandomBalancerStrategy.emitStats(String tier,
         CoordinatorStats stats,
         List<ServerHolder> serverHolderList)  | 
void | 
CostBalancerStrategy.emitStats(String tier,
         CoordinatorStats stats,
         List<ServerHolder> serverHolderList)  | 
void | 
BalancerStrategy.emitStats(String tier,
         CoordinatorStats stats,
         List<ServerHolder> serverHolderList)  | 
ServerHolder | 
RandomBalancerStrategy.findNewSegmentHomeBalancer(io.druid.timeline.DataSegment proposalSegment,
                          List<ServerHolder> serverHolders)  | 
ServerHolder | 
CostBalancerStrategy.findNewSegmentHomeBalancer(io.druid.timeline.DataSegment proposalSegment,
                          List<ServerHolder> serverHolders)  | 
ServerHolder | 
BalancerStrategy.findNewSegmentHomeBalancer(io.druid.timeline.DataSegment proposalSegment,
                          List<ServerHolder> serverHolders)  | 
ServerHolder | 
RandomBalancerStrategy.findNewSegmentHomeReplicator(io.druid.timeline.DataSegment proposalSegment,
                            List<ServerHolder> serverHolders)  | 
ServerHolder | 
CostBalancerStrategy.findNewSegmentHomeReplicator(io.druid.timeline.DataSegment proposalSegment,
                            List<ServerHolder> serverHolders)  | 
ServerHolder | 
BalancerStrategy.findNewSegmentHomeReplicator(io.druid.timeline.DataSegment proposalSegment,
                            List<ServerHolder> serverHolders)  | 
BalancerSegmentHolder | 
ReservoirSegmentSampler.getRandomBalancerSegmentHolder(List<ServerHolder> serverHolders)  | 
BalancerSegmentHolder | 
RandomBalancerStrategy.pickSegmentToMove(List<ServerHolder> serverHolders)  | 
BalancerSegmentHolder | 
CostBalancerStrategy.pickSegmentToMove(List<ServerHolder> serverHolders)  | 
BalancerSegmentHolder | 
BalancerStrategy.pickSegmentToMove(List<ServerHolder> serverHolders)  | 
| Constructor and Description | 
|---|
DruidCluster(Map<String,com.google.common.collect.MinMaxPriorityQueue<ServerHolder>> cluster)  | 
| Modifier and Type | Field and Description | 
|---|---|
static Comparator<ServerHolder> | 
DruidCoordinatorBalancer.percentUsedComparator  | 
Copyright © 2015. All rights reserved.