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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
