1 // Copyright (c) 2011-present, Facebook, Inc.  All rights reserved.
2 //  This source code is licensed under both the GPLv2 (found in the
3 //  COPYING file in the root directory) and Apache 2.0 License
4 //  (found in the LICENSE.Apache file in the root directory).
5 
6 package org.rocksdb;
7 
8 import org.junit.ClassRule;
9 import org.junit.Test;
10 
11 import static org.assertj.core.api.Assertions.assertThat;
12 
13 public class CompactionJobStatsTest {
14 
15   @ClassRule
16   public static final RocksNativeLibraryResource ROCKS_NATIVE_LIBRARY_RESOURCE =
17       new RocksNativeLibraryResource();
18 
19   @Test
reset()20   public void reset() {
21     try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) {
22       compactionJobStats.reset();
23       assertThat(compactionJobStats.elapsedMicros()).isEqualTo(0);
24     }
25   }
26 
27   @Test
add()28   public void add() {
29     try (final CompactionJobStats compactionJobStats = new CompactionJobStats();
30          final CompactionJobStats otherCompactionJobStats = new CompactionJobStats()) {
31       compactionJobStats.add(otherCompactionJobStats);
32     }
33   }
34 
35   @Test
elapsedMicros()36   public void elapsedMicros() {
37     try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) {
38       assertThat(compactionJobStats.elapsedMicros()).isEqualTo(0);
39     }
40   }
41 
42   @Test
numInputRecords()43   public void numInputRecords() {
44     try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) {
45       assertThat(compactionJobStats.numInputRecords()).isEqualTo(0);
46     }
47   }
48 
49   @Test
numInputFiles()50   public void numInputFiles() {
51     try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) {
52       assertThat(compactionJobStats.numInputFiles()).isEqualTo(0);
53     }
54   }
55 
56   @Test
numInputFilesAtOutputLevel()57   public void numInputFilesAtOutputLevel() {
58     try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) {
59       assertThat(compactionJobStats.numInputFilesAtOutputLevel()).isEqualTo(0);
60     }
61   }
62 
63   @Test
numOutputRecords()64   public void numOutputRecords() {
65     try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) {
66       assertThat(compactionJobStats.numOutputRecords()).isEqualTo(0);
67     }
68   }
69 
70   @Test
numOutputFiles()71   public void numOutputFiles() {
72     try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) {
73       assertThat(compactionJobStats.numOutputFiles()).isEqualTo(0);
74     }
75   }
76 
77   @Test
isManualCompaction()78   public void isManualCompaction() {
79     try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) {
80       assertThat(compactionJobStats.isManualCompaction()).isFalse();
81     }
82   }
83 
84   @Test
totalInputBytes()85   public void totalInputBytes() {
86     try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) {
87       assertThat(compactionJobStats.totalInputBytes()).isEqualTo(0);
88     }
89   }
90 
91   @Test
totalOutputBytes()92   public void totalOutputBytes() {
93     try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) {
94       assertThat(compactionJobStats.totalOutputBytes()).isEqualTo(0);
95     }
96   }
97 
98 
99   @Test
numRecordsReplaced()100   public void numRecordsReplaced() {
101     try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) {
102       assertThat(compactionJobStats.numRecordsReplaced()).isEqualTo(0);
103     }
104   }
105 
106   @Test
totalInputRawKeyBytes()107   public void totalInputRawKeyBytes() {
108     try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) {
109       assertThat(compactionJobStats.totalInputRawKeyBytes()).isEqualTo(0);
110     }
111   }
112 
113   @Test
totalInputRawValueBytes()114   public void totalInputRawValueBytes() {
115     try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) {
116       assertThat(compactionJobStats.totalInputRawValueBytes()).isEqualTo(0);
117     }
118   }
119 
120   @Test
numInputDeletionRecords()121   public void numInputDeletionRecords() {
122     try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) {
123       assertThat(compactionJobStats.numInputDeletionRecords()).isEqualTo(0);
124     }
125   }
126 
127   @Test
numExpiredDeletionRecords()128   public void numExpiredDeletionRecords() {
129     try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) {
130       assertThat(compactionJobStats.numExpiredDeletionRecords()).isEqualTo(0);
131     }
132   }
133 
134   @Test
numCorruptKeys()135   public void numCorruptKeys() {
136     try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) {
137       assertThat(compactionJobStats.numCorruptKeys()).isEqualTo(0);
138     }
139   }
140 
141   @Test
fileWriteNanos()142   public void fileWriteNanos() {
143     try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) {
144       assertThat(compactionJobStats.fileWriteNanos()).isEqualTo(0);
145     }
146   }
147 
148   @Test
fileRangeSyncNanos()149   public void fileRangeSyncNanos() {
150     try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) {
151       assertThat(compactionJobStats.fileRangeSyncNanos()).isEqualTo(0);
152     }
153   }
154 
155   @Test
fileFsyncNanos()156   public void fileFsyncNanos() {
157     try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) {
158       assertThat(compactionJobStats.fileFsyncNanos()).isEqualTo(0);
159     }
160   }
161 
162   @Test
filePrepareWriteNanos()163   public void filePrepareWriteNanos() {
164     try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) {
165       assertThat(compactionJobStats.filePrepareWriteNanos()).isEqualTo(0);
166     }
167   }
168 
169   @Test
smallestOutputKeyPrefix()170   public void smallestOutputKeyPrefix() {
171     try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) {
172       assertThat(compactionJobStats.smallestOutputKeyPrefix()).isEmpty();
173     }
174   }
175 
176   @Test
largestOutputKeyPrefix()177   public void largestOutputKeyPrefix() {
178     try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) {
179       assertThat(compactionJobStats.largestOutputKeyPrefix()).isEmpty();
180     }
181   }
182 
183   @Test
numSingleDelFallthru()184   public void numSingleDelFallthru() {
185     try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) {
186       assertThat(compactionJobStats.numSingleDelFallthru()).isEqualTo(0);
187     }
188   }
189 
190   @Test
numSingleDelMismatch()191   public void numSingleDelMismatch() {
192     try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) {
193       assertThat(compactionJobStats.numSingleDelMismatch()).isEqualTo(0);
194     }
195   }
196 }
197