1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.apache.hadoop.hbase.io;
20
21 import org.apache.hadoop.hbase.CompatibilityFactory;
22 import org.apache.hadoop.hbase.test.MetricsAssertHelper;
23 import org.apache.hadoop.hbase.testclassification.SmallTests;
24 import org.junit.Test;
25 import org.junit.experimental.categories.Category;
26
27 @Category(SmallTests.class)
28 public class TestMetricsIO {
29
30 public MetricsAssertHelper HELPER = CompatibilityFactory.getInstance(MetricsAssertHelper.class);
31
32 @Test
33 public void testMetrics() {
34 MetricsIO metrics = new MetricsIO(new MetricsIOWrapper() {
35 @Override
36 public long getChecksumFailures() { return 40; }
37 });
38
39 metrics.updateFsReadTime(100);
40 metrics.updateFsReadTime(200);
41
42 metrics.updateFsPreadTime(300);
43
44 metrics.updateFsWriteTime(400);
45 metrics.updateFsWriteTime(500);
46 metrics.updateFsWriteTime(600);
47
48 HELPER.assertCounter("fsChecksumFailureCount", 40, metrics.getMetricsSource());
49
50 HELPER.assertCounter("fsReadTime_numOps", 2, metrics.getMetricsSource());
51 HELPER.assertCounter("fsPReadTime_numOps", 1, metrics.getMetricsSource());
52 HELPER.assertCounter("fsWriteTime_numOps", 3, metrics.getMetricsSource());
53 }
54 }