Skip to content

Commit c1633d7

Browse files
HBASE-30242 reimplement ratio as uncompressed / compressed
1 parent e8d6c6e commit c1633d7

5 files changed

Lines changed: 8 additions & 8 deletions

File tree

hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSource.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -248,8 +248,8 @@ public interface MetricsRegionServerSource extends BaseSource, JvmPauseMonitorSo
248248
"Bytes per second by which the size of storefiles being served grows.";
249249
String STOREFILE_UNCOMPRESSED_SIZE_DESC = "Total uncompressed size of storefiles being served.";
250250
String STOREFILE_COMPRESSION_RATIO_DESC =
251-
"Compression ratio of storefiles (compressed/uncompressed). Lower values indicate better"
252-
+ " compression. Returns 1.0 when there is no data.";
251+
"Compression ratio of storefiles (uncompressed/compressed). Higher values indicate better"
252+
+ " compression. Returns 0.0 when there is no data.";
253253
String TOTAL_REQUEST_COUNT = "totalRequestCount";
254254
String TOTAL_REQUEST_COUNT_DESC =
255255
"Total number of requests this RegionServer has answered; increments the count once for "

hbase-hadoop-compat/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerWrapper.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -122,8 +122,8 @@ public interface MetricsRegionServerWrapper {
122122
long getStoreFileUncompressedSize();
123123

124124
/**
125-
* Get the compression ratio of store files on this region server. This is the ratio of compressed
126-
* on-disk size to uncompressed data size. Returns 1.0 when there is no data.
125+
* Get the compression ratio of store files on this region server. This is the ratio of
126+
* uncompressed data size to compressed on-disk size. Returns 0.0 when there is no data.
127127
*/
128128
double getStoreFileCompressionRatio();
129129

hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerWrapperImpl.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -542,9 +542,9 @@ public long getStoreFileUncompressedSize() {
542542
public double getStoreFileCompressionRatio() {
543543
long uncompressed = aggregate.storeFileUncompressedSize;
544544
if (uncompressed == 0) {
545-
return 1.0;
545+
return 0.0;
546546
}
547-
return (double) aggregate.storeFileSize / uncompressed;
547+
return (double) uncompressed / aggregate.storeFileSize;
548548
}
549549

550550
@Override

hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/MetricsRegionServerWrapperStub.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -94,7 +94,7 @@ public long getStoreFileUncompressedSize() {
9494

9595
@Override
9696
public double getStoreFileCompressionRatio() {
97-
return 0.5;
97+
return 2;
9898
}
9999

100100
@Override

hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestMetricsRegionServer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,7 @@ public void testWrapperSource() {
9191
HELPER.assertGauge("memstoreOffHeapSize", 600, serverSource);
9292
HELPER.assertGauge("storeFileSize", 1900, serverSource);
9393
HELPER.assertGauge("storeFileUncompressedSize", 3800, serverSource);
94-
HELPER.assertGauge("storeFileCompressionRatio", 0.5, serverSource);
94+
HELPER.assertGauge("storeFileCompressionRatio", 2.0, serverSource);
9595
HELPER.assertGauge("storeFileSizeGrowthRate", 50.0, serverSource);
9696
HELPER.assertCounter("totalRequestCount", 899, serverSource);
9797
HELPER.assertCounter("totalRowActionRequestCount",

0 commit comments

Comments
 (0)