Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 4 additions & 1 deletion bin/hbase
Original file line number Diff line number Diff line change
Expand Up @@ -673,7 +673,10 @@ elif [ "$COMMAND" = "hbtop" ] ; then
done
fi

HBASE_OPTS="${HBASE_OPTS} -Dlog4j.configuration=file:${HBASE_HOME}/conf/log4j-hbtop.properties"
if [ -f "${HBASE_HOME}/conf/log4j-hbtop.properties" ] ; then
HBASE_HBTOP_OPTS="${HBASE_HBTOP_OPTS} -Dlog4j.configuration=file:${HBASE_HOME}/conf/log4j-hbtop.properties"
fi
HBASE_OPTS="${HBASE_OPTS} ${HBASE_HBTOP_OPTS}"
else
CLASS=$COMMAND
fi
Expand Down
2 changes: 1 addition & 1 deletion conf/log4j-hbtop.properties
Original file line number Diff line number Diff line change
Expand Up @@ -24,4 +24,4 @@ log4j.appender.console.layout=org.apache.log4j.PatternLayout
log4j.appender.console.layout.ConversionPattern=%d{ISO8601} %-5p [%t] %c{2}: %m%n

# ZooKeeper will still put stuff at WARN
log4j.logger.org.apache.zookeeper=ERROR
log4j.logger.org.apache.zookeeper=ERROR
Original file line number Diff line number Diff line change
Expand Up @@ -55,6 +55,9 @@ public static RecordFilter parse(String filterString, boolean ignoreCase) {
return parse(filterString, Arrays.asList(Field.values()), ignoreCase);
}

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

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -41,13 +41,14 @@ public void refresh(long lastReportTimestamp, long readRequestCount,
previousFilteredReadRequestCount = filteredReadRequestCount;
previousWriteRequestCount = writeRequestCount;
} else if (previousLastReportTimestamp != lastReportTimestamp) {
readRequestCountPerSecond = (readRequestCount - previousReadRequestCount) /
((lastReportTimestamp - previousLastReportTimestamp) / 1000);
long delta = (lastReportTimestamp - previousLastReportTimestamp) / 1000;
if (delta < 1) {
delta = 1;
}
readRequestCountPerSecond = (readRequestCount - previousReadRequestCount) / delta;
filteredReadRequestCountPerSecond =
(filteredReadRequestCount - previousFilteredReadRequestCount) /
((lastReportTimestamp - previousLastReportTimestamp) / 1000);
writeRequestCountPerSecond = (writeRequestCount - previousWriteRequestCount) /
((lastReportTimestamp - previousLastReportTimestamp) / 1000);
(filteredReadRequestCount - previousFilteredReadRequestCount) / delta;
writeRequestCountPerSecond = (writeRequestCount - previousWriteRequestCount) / delta;

previousLastReportTimestamp = lastReportTimestamp;
previousReadRequestCount = readRequestCount;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -129,10 +129,10 @@ public void showFieldScreen(String sortFieldHeader, List<Field> fields,
}
}

public void showScreenDescription(String sortKeyHeader) {
public void showScreenDescription(String sortFieldHeader) {
TerminalPrinter printer = getTerminalPrinter(SCREEN_DESCRIPTION_START_ROW);
printer.startBold().print("Fields Management").stopBold().endOfLine();
printer.print("Current Sort Field: ").startBold().print(sortKeyHeader).stopBold().endOfLine();
printer.print("Current Sort Field: ").startBold().print(sortFieldHeader).stopBold().endOfLine();
printer.print("Navigate with up/down, Right selects for move then <Enter> or Left commits,")
.endOfLine();
printer.print("'d' or <Space> toggles display, 's' sets sort. Use 'q' or <Esc> to end!")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -234,8 +234,8 @@ public ScreenView transitionToFieldScreen(Screen screen, Terminal terminal) {
return new FieldScreenView(screen, terminal,
topScreenModel.getCurrentSortField(), topScreenModel.getFields(),
fieldDisplayMap,
(sortKey, fields, fieldDisplayMap) -> {
topScreenModel.setSortFieldAndFields(sortKey, fields);
(sortField, fields, fieldDisplayMap) -> {
topScreenModel.setSortFieldAndFields(sortField, fields);
this.fieldDisplayMap.clear();
this.fieldDisplayMap.putAll(fieldDisplayMap);
}, topScreenView);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,11 +30,11 @@


@Category(SmallTests.class)
public class RecordTest {
public class TestRecord {

@ClassRule
public static final HBaseClassTestRule CLASS_RULE =
HBaseClassTestRule.forClass(RecordTest.class);
HBaseClassTestRule.forClass(TestRecord.class);

@Test
public void testBuilder() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -38,11 +38,11 @@


@Category(SmallTests.class)
public class RecordFilterTest {
public class TestRecordFilter {

@ClassRule
public static final HBaseClassTestRule CLASS_RULE =
HBaseClassTestRule.forClass(RecordFilterTest.class);
HBaseClassTestRule.forClass(TestRecordFilter.class);

@Test
public void testParseAndBuilder() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -232,7 +232,7 @@ private static void assertRecordInRegionMode(Record record, String namespace, St
long requestCountPerSecond, long readRequestCountPerSecond,
long filteredReadRequestCountPerSecond, long writeCountRequestPerSecond,
Size storeFileSize, Size uncompressedStoreFileSize, int numStoreFiles,
Size memStoreSize, float Locality, String startKey, long compactingCellCount,
Size memStoreSize, float locality, String startKey, long compactingCellCount,
long compactedCellCount, float compactionProgress, String lastMajorCompactionTime) {
assertThat(record.size(), is(22));
assertThat(record.get(Field.NAMESPACE).asString(), is(namespace));
Expand All @@ -255,7 +255,7 @@ private static void assertRecordInRegionMode(Record record, String namespace, St
is(uncompressedStoreFileSize));
assertThat(record.get(Field.NUM_STORE_FILES).asInt(), is(numStoreFiles));
assertThat(record.get(Field.MEM_STORE_SIZE).asSize(), is(memStoreSize));
assertThat(record.get(Field.LOCALITY).asFloat(), is(Locality));
assertThat(record.get(Field.LOCALITY).asFloat(), is(locality));
assertThat(record.get(Field.START_KEY).asString(), is(startKey));
assertThat(record.get(Field.COMPACTING_CELL_COUNT).asLong(), is(compactingCellCount));
assertThat(record.get(Field.COMPACTED_CELL_COUNT).asLong(), is(compactedCellCount));
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,11 +30,11 @@


@Category(SmallTests.class)
public class FieldValueTest {
public class TestFieldValue {

@ClassRule
public static final HBaseClassTestRule CLASS_RULE =
HBaseClassTestRule.forClass(FieldValueTest.class);
HBaseClassTestRule.forClass(TestFieldValue.class);

@Test
public void testParseAndAsSomethingMethod() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -32,10 +32,10 @@
import org.junit.experimental.categories.Category;

@Category(SmallTests.class)
public class ClientModeTest extends ModeTestBase {
public class TestClientMode extends TestModeBase {

@ClassRule public static final HBaseClassTestRule CLASS_RULE =
HBaseClassTestRule.forClass(ClientModeTest.class);
HBaseClassTestRule.forClass(TestClientMode.class);

@Override protected Mode getMode() {
return Mode.CLIENT;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
import org.junit.Test;


public abstract class ModeTestBase {
public abstract class TestModeBase {

@Test
public void testGetRecords() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -32,11 +32,11 @@


@Category(SmallTests.class)
public class NamespaceModeTest extends ModeTestBase {
public class TestNamespaceMode extends TestModeBase {

@ClassRule
public static final HBaseClassTestRule CLASS_RULE =
HBaseClassTestRule.forClass(NamespaceModeTest.class);
HBaseClassTestRule.forClass(TestNamespaceMode.class);

@Override
protected Mode getMode() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -31,11 +31,11 @@


@Category(SmallTests.class)
public class RegionModeTest extends ModeTestBase {
public class TestRegionMode extends TestModeBase {

@ClassRule
public static final HBaseClassTestRule CLASS_RULE =
HBaseClassTestRule.forClass(RegionModeTest.class);
HBaseClassTestRule.forClass(TestRegionMode.class);

@Override
protected Mode getMode() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -32,11 +32,11 @@


@Category(SmallTests.class)
public class RegionServerModeTest extends ModeTestBase {
public class TestRegionServerMode extends TestModeBase {

@ClassRule
public static final HBaseClassTestRule CLASS_RULE =
HBaseClassTestRule.forClass(RegionServerModeTest.class);
HBaseClassTestRule.forClass(TestRegionServerMode.class);

@Override
protected Mode getMode() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,11 +28,11 @@


@Category(SmallTests.class)
public class RequestCountPerSecondTest {
public class TestRequestCountPerSecond {

@ClassRule
public static final HBaseClassTestRule CLASS_RULE =
HBaseClassTestRule.forClass(RequestCountPerSecondTest.class);
HBaseClassTestRule.forClass(TestRequestCountPerSecond.class);

@Test
public void test() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -32,11 +32,11 @@


@Category(SmallTests.class)
public class TableModeTest extends ModeTestBase {
public class TestTableMode extends TestModeBase {

@ClassRule
public static final HBaseClassTestRule CLASS_RULE =
HBaseClassTestRule.forClass(TableModeTest.class);
HBaseClassTestRule.forClass(TestTableMode.class);

@Override
protected Mode getMode() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -32,11 +32,11 @@
import org.junit.experimental.categories.Category;

@Category(SmallTests.class)
public class UserModeTest extends ModeTestBase {
public class TestUserMode extends TestModeBase {

@ClassRule
public static final HBaseClassTestRule CLASS_RULE =
HBaseClassTestRule.forClass(UserModeTest.class);
HBaseClassTestRule.forClass(TestUserMode.class);

@Override
protected Mode getMode() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -47,11 +47,11 @@

@Category(SmallTests.class)
@RunWith(MockitoJUnitRunner.class)
public class FieldScreenPresenterTest {
public class TestFieldScreenPresenter {

@ClassRule
public static final HBaseClassTestRule CLASS_RULE =
HBaseClassTestRule.forClass(FieldScreenPresenterTest.class);
HBaseClassTestRule.forClass(TestFieldScreenPresenter.class);

@Mock
private FieldScreenView fieldScreenView;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -37,11 +37,11 @@

@Category(SmallTests.class)
@RunWith(MockitoJUnitRunner.class)
public class HelpScreenPresenterTest {
public class TestHelpScreenPresenter {

@ClassRule
public static final HBaseClassTestRule CLASS_RULE =
HBaseClassTestRule.forClass(HelpScreenPresenterTest.class);
HBaseClassTestRule.forClass(TestHelpScreenPresenter.class);

private static final long TEST_REFRESH_DELAY = 5;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -40,11 +40,11 @@

@Category(SmallTests.class)
@RunWith(MockitoJUnitRunner.class)
public class ModeScreenPresenterTest {
public class TestModeScreenPresenter {

@ClassRule
public static final HBaseClassTestRule CLASS_RULE =
HBaseClassTestRule.forClass(ModeScreenPresenterTest.class);
HBaseClassTestRule.forClass(TestModeScreenPresenter.class);

@Mock
private ModeScreenView modeScreenView;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -42,11 +42,11 @@

@Category(SmallTests.class)
@RunWith(MockitoJUnitRunner.class)
public class FilterDisplayModeScreenPresenterTest {
public class TestFilterDisplayModeScreenPresenter {

@ClassRule
public static final HBaseClassTestRule CLASS_RULE =
HBaseClassTestRule.forClass(FilterDisplayModeScreenPresenterTest.class);
HBaseClassTestRule.forClass(TestFilterDisplayModeScreenPresenter.class);

@Mock
private FilterDisplayModeScreenView filterDisplayModeScreenView;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -43,11 +43,11 @@

@Category(SmallTests.class)
@RunWith(MockitoJUnitRunner.class)
public class InputModeScreenPresenterTest {
public class TestInputModeScreenPresenter {

@ClassRule
public static final HBaseClassTestRule CLASS_RULE =
HBaseClassTestRule.forClass(InputModeScreenPresenterTest.class);
HBaseClassTestRule.forClass(TestInputModeScreenPresenter.class);

private static final String TEST_INPUT_MESSAGE = "test input message";

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -35,11 +35,11 @@

@Category(SmallTests.class)
@RunWith(MockitoJUnitRunner.class)
public class MessageModeScreenPresenterTest {
public class TestMessageModeScreenPresenter {

@ClassRule
public static final HBaseClassTestRule CLASS_RULE =
HBaseClassTestRule.forClass(MessageModeScreenPresenterTest.class);
HBaseClassTestRule.forClass(TestMessageModeScreenPresenter.class);

private static final String TEST_MESSAGE = "test message";

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,11 +28,11 @@


@Category(SmallTests.class)
public class PagingTest {
public class TestPaging {

@ClassRule
public static final HBaseClassTestRule CLASS_RULE =
HBaseClassTestRule.forClass(PagingTest.class);
HBaseClassTestRule.forClass(TestPaging.class);

@Test
public void testArrowUpAndArrowDown() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -47,11 +47,11 @@

@Category(SmallTests.class)
@RunWith(MockitoJUnitRunner.class)
public class TopScreenModelTest {
public class TestTopScreenModel {

@ClassRule
public static final HBaseClassTestRule CLASS_RULE =
HBaseClassTestRule.forClass(TopScreenModelTest.class);
HBaseClassTestRule.forClass(TestTopScreenModel.class);

@Mock
private Admin admin;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -45,11 +45,11 @@

@Category(SmallTests.class)
@RunWith(MockitoJUnitRunner.class)
public class TopScreenPresenterTest {
public class TestTopScreenPresenter {

@ClassRule
public static final HBaseClassTestRule CLASS_RULE =
HBaseClassTestRule.forClass(TopScreenPresenterTest.class);
HBaseClassTestRule.forClass(TestTopScreenPresenter.class);

private static final List<FieldInfo> TEST_FIELD_INFOS = Arrays.asList(
new FieldInfo(Field.REGION, 10, true),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,15 +15,17 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.hadoop.hbase.hbtop.terminal;
package org.apache.hadoop.hbase.hbtop.terminal.impl;

import java.util.concurrent.TimeUnit;
import org.apache.hadoop.hbase.hbtop.terminal.impl.TerminalImpl;

import org.apache.hadoop.hbase.hbtop.terminal.KeyPress;
import org.apache.hadoop.hbase.hbtop.terminal.Terminal;

public final class CursorTest {

private CursorTest() {
public final class TestCursor {

private TestCursor() {
}

public static void main(String[] args) throws Exception {
Expand Down
Loading