| Package | Description | 
|---|---|
| io.druid.server.coordinator | |
| io.druid.server.coordinator.helper | 
| Modifier and Type | Method and Description | 
|---|---|
ServerHolder | 
RandomBalancerStrategy.findNewSegmentHomeBalancer(DataSegment proposalSegment,
                          List<ServerHolder> serverHolders)  | 
ServerHolder | 
CostBalancerStrategy.findNewSegmentHomeBalancer(DataSegment proposalSegment,
                          List<ServerHolder> serverHolders)  | 
ServerHolder | 
BalancerStrategy.findNewSegmentHomeBalancer(DataSegment proposalSegment,
                          List<ServerHolder> serverHolders)  | 
ServerHolder | 
RandomBalancerStrategy.findNewSegmentHomeReplicator(DataSegment proposalSegment,
                            List<ServerHolder> serverHolders)  | 
ServerHolder | 
CostBalancerStrategy.findNewSegmentHomeReplicator(DataSegment proposalSegment,
                            List<ServerHolder> serverHolders)  | 
ServerHolder | 
BalancerStrategy.findNewSegmentHomeReplicator(DataSegment proposalSegment,
                            List<ServerHolder> serverHolders)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected Pair<Double,ServerHolder> | 
CostBalancerStrategy.chooseBestServer(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. 
 | 
Collection<ServerHolder> | 
DruidCluster.getAllServers()  | 
Map<String,NavigableSet<ServerHolder>> | 
DruidCluster.getHistoricals()  | 
NavigableSet<ServerHolder> | 
DruidCluster.getHistoricalsByTier(String tier)  | 
Set<ServerHolder> | 
DruidCluster.getRealtimes()  | 
Iterable<NavigableSet<ServerHolder>> | 
DruidCluster.getSortedHistoricalsByTier()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
DruidCluster.add(ServerHolder serverHolder)  | 
int | 
ServerHolder.compareTo(ServerHolder serverHolder)  | 
protected double | 
DiskNormalizedCostBalancerStrategy.computeCost(DataSegment proposalSegment,
           ServerHolder server,
           boolean includeCurrentServer)
Averages the cost obtained from CostBalancerStrategy. 
 | 
protected double | 
CostBalancerStrategy.computeCost(DataSegment proposalSegment,
           ServerHolder server,
           boolean includeCurrentServer)  | 
protected double | 
CachingCostBalancerStrategy.computeCost(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 Pair<Double,ServerHolder> | 
CostBalancerStrategy.chooseBestServer(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(DataSegment proposalSegment,
                          List<ServerHolder> serverHolders)  | 
ServerHolder | 
CostBalancerStrategy.findNewSegmentHomeBalancer(DataSegment proposalSegment,
                          List<ServerHolder> serverHolders)  | 
ServerHolder | 
BalancerStrategy.findNewSegmentHomeBalancer(DataSegment proposalSegment,
                          List<ServerHolder> serverHolders)  | 
ServerHolder | 
RandomBalancerStrategy.findNewSegmentHomeReplicator(DataSegment proposalSegment,
                            List<ServerHolder> serverHolders)  | 
ServerHolder | 
CostBalancerStrategy.findNewSegmentHomeReplicator(DataSegment proposalSegment,
                            List<ServerHolder> serverHolders)  | 
ServerHolder | 
BalancerStrategy.findNewSegmentHomeReplicator(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(Set<ServerHolder> realtimes,
            Map<String,NavigableSet<ServerHolder>> historicals)  | 
DruidCluster(Set<ServerHolder> realtimes,
            Map<String,NavigableSet<ServerHolder>> historicals)  | 
| Modifier and Type | Field and Description | 
|---|---|
static Comparator<ServerHolder> | 
DruidCoordinatorBalancer.percentUsedComparator  | 
Copyright © 2011–2018. All rights reserved.