Package | Description |
---|---|
io.druid.server.coordinator | |
io.druid.server.coordinator.rules |
Modifier and Type | Method and Description |
---|---|
CoordinatorStats |
CoordinatorStats.accumulate(CoordinatorStats stats) |
CoordinatorStats |
DruidCoordinatorRuntimeParams.getCoordinatorStats() |
Modifier and Type | Method and Description |
---|---|
CoordinatorStats |
CoordinatorStats.accumulate(CoordinatorStats stats) |
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) |
DruidCoordinatorRuntimeParams.Builder |
DruidCoordinatorRuntimeParams.Builder.withCoordinatorStats(CoordinatorStats stats) |
Modifier and Type | Method and Description |
---|---|
CoordinatorStats |
Rule.run(DruidCoordinator coordinator,
DruidCoordinatorRuntimeParams params,
DataSegment segment) |
CoordinatorStats |
LoadRule.run(DruidCoordinator coordinator,
DruidCoordinatorRuntimeParams params,
DataSegment segment) |
CoordinatorStats |
DropRule.run(DruidCoordinator coordinator,
DruidCoordinatorRuntimeParams params,
DataSegment segment) |
CoordinatorStats |
BroadcastDistributionRule.run(DruidCoordinator coordinator,
DruidCoordinatorRuntimeParams params,
DataSegment segment) |
Copyright © 2011–2018. All rights reserved.