001/* 002 * Licensed to the Apache Software Foundation (ASF) under one 003 * or more contributor license agreements. See the NOTICE file 004 * distributed with this work for additional information 005 * regarding copyright ownership. The ASF licenses this file 006 * to you under the Apache License, Version 2.0 (the 007 * "License"); you may not use this file except in compliance 008 * with the License. You may obtain a copy of the License at 009 * 010 * http://www.apache.org/licenses/LICENSE-2.0 011 * 012 * Unless required by applicable law or agreed to in writing, software 013 * distributed under the License is distributed on an "AS IS" BASIS, 014 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 015 * See the License for the specific language governing permissions and 016 * limitations under the License. 017 */ 018package org.apache.hadoop.hbase.hbtop.mode; 019 020import static org.hamcrest.CoreMatchers.is; 021import static org.hamcrest.MatcherAssert.assertThat; 022import static org.junit.Assert.fail; 023 024import java.util.List; 025import org.apache.hadoop.hbase.HBaseClassTestRule; 026import org.apache.hadoop.hbase.hbtop.Record; 027import org.apache.hadoop.hbase.hbtop.TestUtils; 028import org.apache.hadoop.hbase.hbtop.field.Field; 029import org.apache.hadoop.hbase.testclassification.SmallTests; 030import org.junit.ClassRule; 031import org.junit.experimental.categories.Category; 032 033@Category(SmallTests.class) 034public class TestTableMode extends TestModeBase { 035 036 @ClassRule 037 public static final HBaseClassTestRule CLASS_RULE = 038 HBaseClassTestRule.forClass(TestTableMode.class); 039 040 @Override 041 protected Mode getMode() { 042 return Mode.TABLE; 043 } 044 045 @Override 046 protected void assertRecords(List<Record> records) { 047 TestUtils.assertRecordsInTableMode(records); 048 } 049 050 @Override 051 protected void assertDrillDown(Record currentRecord, DrillDownInfo drillDownInfo) { 052 assertThat(drillDownInfo.getNextMode(), is(Mode.REGION)); 053 assertThat(drillDownInfo.getInitialFilters().size(), is(2)); 054 055 String tableName = String.format("%s:%s", currentRecord.get(Field.NAMESPACE).asString(), 056 currentRecord.get(Field.TABLE).asString()); 057 058 switch (tableName) { 059 case "default:table1": 060 assertThat(drillDownInfo.getInitialFilters().get(0).toString(), is("NAMESPACE==default")); 061 assertThat(drillDownInfo.getInitialFilters().get(1).toString(), is("TABLE==table1")); 062 break; 063 064 case "default:table2": 065 assertThat(drillDownInfo.getInitialFilters().get(0).toString(), is("NAMESPACE==default")); 066 assertThat(drillDownInfo.getInitialFilters().get(1).toString(), is("TABLE==table2")); 067 break; 068 069 case "namespace:table3": 070 assertThat(drillDownInfo.getInitialFilters().get(0).toString(), is("NAMESPACE==namespace")); 071 assertThat(drillDownInfo.getInitialFilters().get(1).toString(), is("TABLE==table3")); 072 break; 073 074 default: 075 fail(); 076 } 077 } 078}