Apache/druid
1
0
Fork 0
mirror of https://github.com/apache/druid.git synced 2025-02-20 08:56:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

remove some accidentally committed code

Browse Source
This commit is contained in:
fjy 2014-01-20 15:16:17 -08:00
parent 08966c424a
commit 3ff4cc2371
1 changed files with 3 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
server/src/main/java/io/druid/server/coordinator/DruidCoordinator.java
View File

@ -201,32 +201,23 @@ public class DruidCoordinator
for (Rule rule : rules) { for (Rule rule : rules) {
if (rule instanceof LoadRule && rule.appliesTo(segment, now)) { if (rule instanceof LoadRule && rule.appliesTo(segment, now)) {
expectedSegmentsInCluster.add(segment.getDataSource(), ((LoadRule) rule).getReplicants()); expectedSegmentsInCluster.add(segment.getDataSource(), ((LoadRule) rule).getReplicants());
//Integer count = expectedSegmentsInCluster.get(segment.getDataSource());
//if (count == null) {
// count = 0;
//}
//expectedSegmentsInCluster.put(segment.getDataSource(), count + ((LoadRule) rule).getReplicants());
break; break;
} }
} }
} }
// find segments currently loaded per datasource // find segments currently loaded per datasource
Map<String, Integer> segmentsInCluster = Maps.newHashMap(); CountingMap<String> segmentsInCluster = new CountingMap<>();
for (DruidServer druidServer : serverInventoryView.getInventory()) { for (DruidServer druidServer : serverInventoryView.getInventory()) {
for (DataSegment segment : druidServer.getSegments().values()) { for (DataSegment segment : druidServer.getSegments().values()) {
Integer count = segmentsInCluster.get(segment.getDataSource()); segmentsInCluster.add(segment.getDataSource(), 1);
if (count == null) {
count = 0;
}
segmentsInCluster.put(segment.getDataSource(), count + 1);
} }
} }
// compare available segments with currently loaded // compare available segments with currently loaded
Map<String, Double> loadStatus = Maps.newHashMap(); Map<String, Double> loadStatus = Maps.newHashMap();
for (Map.Entry<String, AtomicLong> entry : expectedSegmentsInCluster.entrySet()) { for (Map.Entry<String, AtomicLong> entry : expectedSegmentsInCluster.entrySet()) {
Integer actual = segmentsInCluster.get(entry.getKey()); Long actual = segmentsInCluster.get(entry.getKey()).get();
loadStatus.put(entry.getKey(), 100 * (actual == null ? 0.0D : (double) actual) / entry.getValue().get()); loadStatus.put(entry.getKey(), 100 * (actual == null ? 0.0D : (double) actual) / entry.getValue().get());
} }