add some debug logging to see how many writes we do per batch

hawkular · Sep 8, 2015 · 1a12172 · 1a12172
1 parent 419a9ce
commit 1a12172
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/core/metrics-core-impl/src/main/java/org/hawkular/metrics/core/impl/MetricsServiceImpl.java b/core/metrics-core-impl/src/main/java/org/hawkular/metrics/core/impl/MetricsServiceImpl.java
@@ -605,7 +605,8 @@ public <T> Observable<Void> addDataPoints(MetricType<T> metricType, Observable<M
 
         Observable<Integer> tenantUpdates = updateTenantBuckets(metrics);
 
-        Observable<Integer> indexUpdates = dataAccess.updateMetricsIndex(metrics);
+        Observable<Integer> indexUpdates = dataAccess.updateMetricsIndex(metrics)
+                .doOnNext(batchSize -> logger.debug("Inserted {} {} metrics into metrics_idx", batchSize, metricType));
         return Observable.concat(updates, indexUpdates, tenantUpdates)
                 .takeLast(1)
                 .map(count -> null);