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) |
Constructor and Description |
---|
DruidCoordinatorRuntimeParams(long startTime,
DruidCluster druidCluster,
MetadataRuleManager databaseRuleManager,
SegmentReplicantLookup segmentReplicantLookup,
Set<DruidDataSource> dataSources,
Set<io.druid.timeline.DataSegment> availableSegments,
Map<String,LoadQueuePeon> loadManagementPeons,
ReplicationThrottler replicationManager,
com.metamx.emitter.service.ServiceEmitter emitter,
CoordinatorDynamicConfig coordinatorDynamicConfig,
CoordinatorStats stats,
org.joda.time.DateTime balancerReferenceTimestamp,
BalancerStrategyFactory strategyFactory) |
Modifier and Type | Method and Description |
---|---|
CoordinatorStats |
Rule.run(DruidCoordinator coordinator,
DruidCoordinatorRuntimeParams params,
io.druid.timeline.DataSegment segment) |
CoordinatorStats |
LoadRule.run(DruidCoordinator coordinator,
DruidCoordinatorRuntimeParams params,
io.druid.timeline.DataSegment segment) |
CoordinatorStats |
DropRule.run(DruidCoordinator coordinator,
DruidCoordinatorRuntimeParams params,
io.druid.timeline.DataSegment segment) |
Copyright © 2011–2015. All rights reserved.