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

add total segment size/count metric

This commit is contained in:
Xavier Léauté 2013-11-18 13:51:06 -08:00
parent f66fe3cbbb
commit 1e9d72d95a
1 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
server/src/main/java/io/druid/server/metrics/ServerMonitor.java
View File

@ -47,9 +47,14 @@ public class ServerMonitor extends AbstractMonitor
public boolean doMonitor(ServiceEmitter emitter) public boolean doMonitor(ServiceEmitter emitter)
{ {
emitter.emit(new ServiceMetricEvent.Builder().build("server/segment/max", serverConfig.getMaxSize())); emitter.emit(new ServiceMetricEvent.Builder().build("server/segment/max", serverConfig.getMaxSize()));
long totalUsed = 0;
long totalCount = 0;
for (Map.Entry<String, Long> entry : serverManager.getDataSourceSizes().entrySet()) { for (Map.Entry<String, Long> entry : serverManager.getDataSourceSizes().entrySet()) {
String dataSource = entry.getKey(); String dataSource = entry.getKey();
long used = entry.getValue(); long used = entry.getValue();
totalUsed += used;
final ServiceMetricEvent.Builder builder = new ServiceMetricEvent.Builder().setUser1(dataSource) final ServiceMetricEvent.Builder builder = new ServiceMetricEvent.Builder().setUser1(dataSource)
.setUser2(serverConfig.getTier()); .setUser2(serverConfig.getTier());
@ -60,12 +65,18 @@ public class ServerMonitor extends AbstractMonitor
for (Map.Entry<String, Long> entry : serverManager.getDataSourceCounts().entrySet()) { for (Map.Entry<String, Long> entry : serverManager.getDataSourceCounts().entrySet()) {
String dataSource = entry.getKey(); String dataSource = entry.getKey();
long count = entry.getValue(); long count = entry.getValue();
totalCount += count;
final ServiceMetricEvent.Builder builder = new ServiceMetricEvent.Builder().setUser1(dataSource) final ServiceMetricEvent.Builder builder = new ServiceMetricEvent.Builder().setUser1(dataSource)
.setUser2(serverConfig.getTier()); .setUser2(serverConfig.getTier());
emitter.emit(builder.build("server/segment/count", count)); emitter.emit(builder.build("server/segment/count", count));
} }
final ServiceMetricEvent.Builder builder = new ServiceMetricEvent.Builder().setUser2(serverConfig.getTier());
emitter.emit(builder.build("server/segment/totalUsed", totalUsed));
emitter.emit(builder.build("server/segment/totalUsedPercent", totalUsed / (double) serverConfig.getMaxSize()));
emitter.emit(builder.build("server/segment/totalCount", totalCount));
return true; return true;
} }
} }