Skip to content

Commit 5598d26

Browse files
committed
HBASE-23165 [hbtop] Some modifications from HBASE-22988 (apache#987)
Signed-off-by: stack <stack@apache.org>
1 parent b0a1ecd commit 5598d26

28 files changed

+75
-61
lines changed

bin/hbase

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -637,7 +637,10 @@ elif [ "$COMMAND" = "hbtop" ] ; then
637637
done
638638
fi
639639

640-
HBASE_OPTS="${HBASE_OPTS} -Dlog4j.configuration=file:${HBASE_HOME}/conf/log4j-hbtop.properties"
640+
if [ -f "${HBASE_HOME}/conf/log4j-hbtop.properties" ] ; then
641+
HBASE_HBTOP_OPTS="${HBASE_HBTOP_OPTS} -Dlog4j.configuration=file:${HBASE_HOME}/conf/log4j-hbtop.properties"
642+
fi
643+
HBASE_OPTS="${HBASE_OPTS} ${HBASE_HBTOP_OPTS}"
641644
else
642645
CLASS=$COMMAND
643646
fi

conf/log4j-hbtop.properties

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,4 +24,4 @@ log4j.appender.console.layout=org.apache.log4j.PatternLayout
2424
log4j.appender.console.layout.ConversionPattern=%d{ISO8601} %-5p [%t] %c{2}: %m%n
2525

2626
# ZooKeeper will still put stuff at WARN
27-
log4j.logger.org.apache.zookeeper=ERROR
27+
log4j.logger.org.apache.zookeeper=ERROR

hbase-hbtop/src/main/java/org/apache/hadoop/hbase/hbtop/RecordFilter.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -55,6 +55,9 @@ public static RecordFilter parse(String filterString, boolean ignoreCase) {
5555
return parse(filterString, Arrays.asList(Field.values()), ignoreCase);
5656
}
5757

58+
/*
59+
* Parse a filter string and build a RecordFilter instance.
60+
*/
5861
public static RecordFilter parse(String filterString, List<Field> fields, boolean ignoreCase) {
5962
int index = 0;
6063

hbase-hbtop/src/main/java/org/apache/hadoop/hbase/hbtop/mode/RequestCountPerSecond.java

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -41,13 +41,14 @@ public void refresh(long lastReportTimestamp, long readRequestCount,
4141
previousFilteredReadRequestCount = filteredReadRequestCount;
4242
previousWriteRequestCount = writeRequestCount;
4343
} else if (previousLastReportTimestamp != lastReportTimestamp) {
44-
readRequestCountPerSecond = (readRequestCount - previousReadRequestCount) /
45-
((lastReportTimestamp - previousLastReportTimestamp) / 1000);
44+
long delta = (lastReportTimestamp - previousLastReportTimestamp) / 1000;
45+
if (delta < 1) {
46+
delta = 1;
47+
}
48+
readRequestCountPerSecond = (readRequestCount - previousReadRequestCount) / delta;
4649
filteredReadRequestCountPerSecond =
47-
(filteredReadRequestCount - previousFilteredReadRequestCount) /
48-
((lastReportTimestamp - previousLastReportTimestamp) / 1000);
49-
writeRequestCountPerSecond = (writeRequestCount - previousWriteRequestCount) /
50-
((lastReportTimestamp - previousLastReportTimestamp) / 1000);
50+
(filteredReadRequestCount - previousFilteredReadRequestCount) / delta;
51+
writeRequestCountPerSecond = (writeRequestCount - previousWriteRequestCount) / delta;
5152

5253
previousLastReportTimestamp = lastReportTimestamp;
5354
previousReadRequestCount = readRequestCount;

hbase-hbtop/src/main/java/org/apache/hadoop/hbase/hbtop/screen/field/FieldScreenView.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -129,10 +129,10 @@ public void showFieldScreen(String sortFieldHeader, List<Field> fields,
129129
}
130130
}
131131

132-
public void showScreenDescription(String sortKeyHeader) {
132+
public void showScreenDescription(String sortFieldHeader) {
133133
TerminalPrinter printer = getTerminalPrinter(SCREEN_DESCRIPTION_START_ROW);
134134
printer.startBold().print("Fields Management").stopBold().endOfLine();
135-
printer.print("Current Sort Field: ").startBold().print(sortKeyHeader).stopBold().endOfLine();
135+
printer.print("Current Sort Field: ").startBold().print(sortFieldHeader).stopBold().endOfLine();
136136
printer.print("Navigate with up/down, Right selects for move then <Enter> or Left commits,")
137137
.endOfLine();
138138
printer.print("'d' or <Space> toggles display, 's' sets sort. Use 'q' or <Esc> to end!")

hbase-hbtop/src/main/java/org/apache/hadoop/hbase/hbtop/screen/top/TopScreenPresenter.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -233,8 +233,8 @@ public ScreenView transitionToFieldScreen(Screen screen, Terminal terminal) {
233233
return new FieldScreenView(screen, terminal,
234234
topScreenModel.getCurrentSortField(), topScreenModel.getFields(),
235235
fieldDisplayMap,
236-
(sortKey, fields, fieldDisplayMap) -> {
237-
topScreenModel.setSortFieldAndFields(sortKey, fields);
236+
(sortField, fields, fieldDisplayMap) -> {
237+
topScreenModel.setSortFieldAndFields(sortField, fields);
238238
this.fieldDisplayMap.clear();
239239
this.fieldDisplayMap.putAll(fieldDisplayMap);
240240
}, topScreenView);

hbase-hbtop/src/test/java/org/apache/hadoop/hbase/hbtop/RecordTest.java renamed to hbase-hbtop/src/test/java/org/apache/hadoop/hbase/hbtop/TestRecord.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,11 +30,11 @@
3030

3131

3232
@Category(SmallTests.class)
33-
public class RecordTest {
33+
public class TestRecord {
3434

3535
@ClassRule
3636
public static final HBaseClassTestRule CLASS_RULE =
37-
HBaseClassTestRule.forClass(RecordTest.class);
37+
HBaseClassTestRule.forClass(TestRecord.class);
3838

3939
@Test
4040
public void testBuilder() {

hbase-hbtop/src/test/java/org/apache/hadoop/hbase/hbtop/RecordFilterTest.java renamed to hbase-hbtop/src/test/java/org/apache/hadoop/hbase/hbtop/TestRecordFilter.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -38,11 +38,11 @@
3838

3939

4040
@Category(SmallTests.class)
41-
public class RecordFilterTest {
41+
public class TestRecordFilter {
4242

4343
@ClassRule
4444
public static final HBaseClassTestRule CLASS_RULE =
45-
HBaseClassTestRule.forClass(RecordFilterTest.class);
45+
HBaseClassTestRule.forClass(TestRecordFilter.class);
4646

4747
@Test
4848
public void testParseAndBuilder() {

hbase-hbtop/src/test/java/org/apache/hadoop/hbase/hbtop/TestUtils.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -213,7 +213,7 @@ private static void assertRecordInRegionMode(Record record, String namespace, St
213213
long requestCountPerSecond, long readRequestCountPerSecond,
214214
long filteredReadRequestCountPerSecond, long writeCountRequestPerSecond,
215215
Size storeFileSize, Size uncompressedStoreFileSize, int numStoreFiles,
216-
Size memStoreSize, float Locality, String startKey, long compactingCellCount,
216+
Size memStoreSize, float locality, String startKey, long compactingCellCount,
217217
long compactedCellCount, float compactionProgress, String lastMajorCompactionTime) {
218218
assertThat(record.size(), is(22));
219219
assertThat(record.get(Field.NAMESPACE).asString(), is(namespace));
@@ -236,7 +236,7 @@ private static void assertRecordInRegionMode(Record record, String namespace, St
236236
is(uncompressedStoreFileSize));
237237
assertThat(record.get(Field.NUM_STORE_FILES).asInt(), is(numStoreFiles));
238238
assertThat(record.get(Field.MEM_STORE_SIZE).asSize(), is(memStoreSize));
239-
assertThat(record.get(Field.LOCALITY).asFloat(), is(Locality));
239+
assertThat(record.get(Field.LOCALITY).asFloat(), is(locality));
240240
assertThat(record.get(Field.START_KEY).asString(), is(startKey));
241241
assertThat(record.get(Field.COMPACTING_CELL_COUNT).asLong(), is(compactingCellCount));
242242
assertThat(record.get(Field.COMPACTED_CELL_COUNT).asLong(), is(compactedCellCount));

hbase-hbtop/src/test/java/org/apache/hadoop/hbase/hbtop/field/FieldValueTest.java renamed to hbase-hbtop/src/test/java/org/apache/hadoop/hbase/hbtop/field/TestFieldValue.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,11 +30,11 @@
3030

3131

3232
@Category(SmallTests.class)
33-
public class FieldValueTest {
33+
public class TestFieldValue {
3434

3535
@ClassRule
3636
public static final HBaseClassTestRule CLASS_RULE =
37-
HBaseClassTestRule.forClass(FieldValueTest.class);
37+
HBaseClassTestRule.forClass(TestFieldValue.class);
3838

3939
@Test
4040
public void testParseAndAsSomethingMethod() {

0 commit comments

Comments
 (0)