Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix per tier metrics emission for new balancer

This commit is contained in:
Nelson Ray 2013-03-25 10:32:02 -07:00
parent dcd10e69c7
commit a28de5fa88
1 changed files with 65 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

60
server/src/main/java/com/metamx/druid/master/DruidMasterLogger.java
View File

@ -65,35 +65,75 @@ public class DruidMasterLogger implements DruidMasterHelper
}
}
Map<String, AtomicLong> initialCosts = stats.getPerTierStats().get("initialCost");
if (initialCosts != null) {
for (Map.Entry<String, AtomicLong> entry : initialCosts.entrySet()) {
String tier = entry.getKey();
AtomicLong value = entry.getValue();
emitter.emit(
new ServiceMetricEvent.Builder().build(
"master/cost/raw", stats.getGlobalStats().get("initialCost")
new ServiceMetricEvent.Builder()
.build(
String.format("master/%s/cost/raw", tier), value.get()
)
);
}
}
Map<String, AtomicLong> normalization = stats.getPerTierStats().get("normalization");
if (initialCosts != null) {
for (Map.Entry<String, AtomicLong> entry : normalization.entrySet()) {
String tier = entry.getKey();
AtomicLong value = entry.getValue();
emitter.emit(
new ServiceMetricEvent.Builder().build(
"master/cost/normalization", stats.getGlobalStats().get("normalization")
new ServiceMetricEvent.Builder()
.build(
String.format("master/%s/cost/normalization", tier), value.get()
)
);
}
}
Map<String, AtomicLong> normalized = stats.getPerTierStats().get("normalizedInitialCostTimesOneThousand");
if (initialCosts != null) {
for (Map.Entry<String, AtomicLong> entry : normalized.entrySet()) {
String tier = entry.getKey();
AtomicLong value = entry.getValue();
emitter.emit(
new ServiceMetricEvent.Builder().build(
"master/cost/normalized", stats.getGlobalStats().get("normalizedInitialCostTimesOneThousand").doubleValue() / 1000d
new ServiceMetricEvent.Builder()
.build(
String.format("master/%s/cost/normalized", tier), (double) value.get() / 1000d
)
);
}
}
Map<String, AtomicLong> movedCount = stats.getPerTierStats().get("movedCount");
if (initialCosts != null) {
for (Map.Entry<String, AtomicLong> entry : movedCount.entrySet()) {
String tier = entry.getKey();
AtomicLong value = entry.getValue();
emitter.emit(
new ServiceMetricEvent.Builder().build(
"master/moved/count", stats.getGlobalStats().get("movedCount")
new ServiceMetricEvent.Builder()
.build(
String.format("master/%s/moved/count", tier), value.get()
)
);
}
}
Map<String, AtomicLong> deletedCount = stats.getPerTierStats().get("deletedCount");
if (initialCosts != null) {
for (Map.Entry<String, AtomicLong> entry : deletedCount.entrySet()) {
String tier = entry.getKey();
AtomicLong value = entry.getValue();
emitter.emit(
new ServiceMetricEvent.Builder().build(
"master/deleted/count", stats.getGlobalStats().get("deletedCount")
new ServiceMetricEvent.Builder()
.build(
String.format("master/%s/deleted/count", tier), value.get()
)
);
}
}
Map<String, AtomicLong> unneeded = stats.getPerTierStats().get("unneededCount");
if (unneeded != null) {