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 © 2011–2015. All rights reserved.