partial test

Author: bbeaudreault

hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestLookupRegionMetaFamilyFilter.java

@@ -0,0 +1,82 @@
+package org.apache.hadoop.hbase.client;
+
+import java.io.IOException;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.hadoop.hbase.HBaseTestingUtility;
+import org.apache.hadoop.hbase.HColumnDescriptor;
+import org.apache.hadoop.hbase.HConstants;
+import org.apache.hadoop.hbase.HRegionInfo;
+import org.apache.hadoop.hbase.HTableDescriptor;
+import org.apache.hadoop.hbase.TableName;
+import org.apache.hadoop.hbase.testclassification.MediumTests;
+import org.apache.hadoop.hbase.util.Bytes;
+import org.junit.After;
+import org.junit.BeforeClass;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+@Category(MediumTests.class)
+public class TestLookupRegionMetaFamilyFilter {
+  private static final Log LOG = LogFactory.getLog(TestLookupRegionMetaFamilyFilter.class);
+
+  private static String EXTRA_CF = "test";
+  private static byte[] EXTRA_CF_BYTES = Bytes.toBytes(EXTRA_CF);
+
+  private static TableName TABLE = TableName.valueOf("foo");
+  private static HBaseTestingUtility TEST_UTIL;
+
+  @BeforeClass
+  public static void beforeClass() throws Exception {
+    if (TEST_UTIL != null) {
+      // We reached end of a parameterized run, clean up.
+      TEST_UTIL.shutdownMiniCluster();
+    }
+    TEST_UTIL = new HBaseTestingUtility();
+    TEST_UTIL.startMiniCluster(1);
+  }
+
+  @After
+  public void tearDown() throws Exception {
+    TEST_UTIL.shutdownMiniCluster();
+  }
+
+  @Test
+  public void testCatalogFamilyFilter() throws IOException, InterruptedException {
+
+    HBaseAdmin admin = TEST_UTIL.getHBaseAdmin();
+    admin.createTable(new HTableDescriptor(TABLE).addFamily(new HColumnDescriptor(EXTRA_CF)));
+    admin.split(TABLE, Bytes.toBytes("55555"));
+
+    while (admin.getTableRegions(TABLE).size() != 2) {
+      LOG.info("Waiting for 2 regions in table");
+      Thread.sleep(1000);
+    }
+
+    byte[] testRow = Bytes.toBytes("44444");
+
+    admin.addColumn(TableName.META_TABLE_NAME, new HColumnDescriptor(EXTRA_CF));
+
+    Table metaTable = TEST_UTIL.getConnection().getTable(TableName.META_TABLE_NAME);
+    try {
+      byte[] metaKey = HRegionInfo.createRegionName(TABLE, testRow, HConstants.NINES, false);
+      Put put = new Put(metaKey);
+      put.addColumn(EXTRA_CF_BYTES, EXTRA_CF_BYTES, Bytes.toBytes("unused val"));
+      metaTable.put(put);
+    } finally {
+      metaTable.close();
+    }
+
+    Table table = TEST_UTIL.getConnection().getTable(TABLE);
+
+    try {
+      Get get = new Get(testRow);
+      // we don't expect or care about a result here.
+      // instead, we just want it to succeed, which proves that meta is
+      // properly filtering on the correct family
+      table.get(get);
+    } finally {
+      table.close();
+    }
+  }
+}