[cassandra] branch trunk updated: Add UnleveledSSTables table level metric

[spod]

This is an automated email from the ASF dual-hosted git repository.

spod pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 1916e5d  Add UnleveledSSTables table level metric
1916e5d is described below

commit 1916e5d1ca6ed526a65c4fef7ff933de70006496
Author: Stefan Podkowinski <s.podkowin...@gmail.com>
AuthorDate: Tue Mar 3 13:09:43 2020 +0100

    Add UnleveledSSTables table level metric
    
    patch by Stefan Podkowinski; reviewed by Chris Lohfink for CASSANDRA-15620
---
 CHANGES.txt                                             |  1 +
 src/java/org/apache/cassandra/metrics/TableMetrics.java | 12 ++++++++++++
 2 files changed, 13 insertions(+)

diff --git a/CHANGES.txt b/CHANGES.txt
index e418db7..d863df2 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -1,4 +1,5 @@
 4.0-alpha4
+ * Added UnleveledSSTables global and table level metric (CASSANDRA-15620)
  * Added Virtual Table exposing Cassandra relevant system properties 
(CASSANDRA-15616)
  * Add data modeling introduction (CASSANDRA-15481)
  * Improve the algorithmic token allocation in case racks = RF 
(CASSANDRA-15600)
diff --git a/src/java/org/apache/cassandra/metrics/TableMetrics.java 
b/src/java/org/apache/cassandra/metrics/TableMetrics.java
index d8330cc..6095f50 100644
--- a/src/java/org/apache/cassandra/metrics/TableMetrics.java
+++ b/src/java/org/apache/cassandra/metrics/TableMetrics.java
@@ -218,6 +218,8 @@ public class TableMetrics
     public final Counter additionalWrites;
     public final Gauge<Long> additionalWriteLatencyNanos;
 
+    public final Gauge<Integer> unleveledSSTables;
+
     /**
      * Metrics for inconsistencies detected between repaired data sets across 
replicas. These
      * are tracked on the coordinator.
@@ -943,6 +945,16 @@ public class TableMetrics
 
         confirmedRepairedInconsistencies = 
createTableMeter("RepairedDataInconsistenciesConfirmed", 
cfs.keyspace.metric.confirmedRepairedInconsistencies);
         unconfirmedRepairedInconsistencies = 
createTableMeter("RepairedDataInconsistenciesUnconfirmed", 
cfs.keyspace.metric.unconfirmedRepairedInconsistencies);
+
+        unleveledSSTables = createTableGauge("UnleveledSSTables", 
cfs::getUnleveledSSTables, () -> {
+            // global gauge
+            int cnt = 0;
+            for (Metric cfGauge : allTableMetrics.get("UnleveledSSTables"))
+            {
+                cnt += ((Gauge<? extends Number>) 
cfGauge).getValue().intValue();
+            }
+            return cnt;
+        });
     }
 
     public void updateSSTableIterated(int count)


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org
For additional commands, e-mail: commits-h...@cassandra.apache.org