Package org.apache.hadoop.hbase.master.janitor

Class TestCatalogJanitorCluster

java.lang.Object

org.apache.hadoop.hbase.master.janitor.TestCatalogJanitorCluster

public class TestCatalogJanitorCluster
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static final org.slf4j.Logger	LOG
final org.junit.rules.TestName	name
private static final org.apache.hadoop.hbase.TableName	T1
private static final org.apache.hadoop.hbase.TableName	T2
private static final org.apache.hadoop.hbase.TableName	T3
private static final org.apache.hadoop.hbase.TableName	T4
private static final org.apache.hadoop.hbase.TableName	T5
private static final org.apache.hadoop.hbase.TableName	T6
private static final org.apache.hadoop.hbase.TableName	T7
private static final HBaseTestingUtility	TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
TestCatalogJanitorCluster()

Method Summary

Modifier and Type	Method	Description
void	after()
void	before()
private void	disableTable(org.apache.hadoop.hbase.TableName tableName)
private void	fixHoles(org.apache.hadoop.hbase.master.janitor.CatalogJanitor janitor)
private LinkedList<org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.hbase.client.RegionInfo,org.apache.hadoop.hbase.client.RegionInfo>>	getHoles(org.apache.hadoop.hbase.master.janitor.CatalogJanitor janitor, org.apache.hadoop.hbase.TableName tableName)
private org.apache.hadoop.hbase.client.RegionInfo	getRegionInfo(org.apache.hadoop.hbase.TableName tableName, byte[] row)
private static byte[]	incrementRow(byte[] row)	Take last byte and add one to it.
void	testConsistency()	Fat method where we start with a fat hbase:meta and then gradually intro problems running catalogjanitor for each to ensure it triggers complaint.
void	testHoles()
private void	verifyCornerHoles(org.apache.hadoop.hbase.master.janitor.CatalogJanitor janitor, org.apache.hadoop.hbase.TableName tableName)
private void	verifyMiddleHole(org.apache.hadoop.hbase.master.janitor.CatalogJanitor janitor)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOG

private static final org.slf4j.Logger LOG

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

name

public final org.junit.rules.TestName name

TEST_UTIL

private static final HBaseTestingUtility TEST_UTIL

T1

private static final org.apache.hadoop.hbase.TableName T1

T2

private static final org.apache.hadoop.hbase.TableName T2

T3

private static final org.apache.hadoop.hbase.TableName T3

T4

private static final org.apache.hadoop.hbase.TableName T4

T5

private static final org.apache.hadoop.hbase.TableName T5

T6

private static final org.apache.hadoop.hbase.TableName T6

T7

private static final org.apache.hadoop.hbase.TableName T7

Constructor Details

TestCatalogJanitorCluster

public TestCatalogJanitorCluster()

Method Details

before

public void before()
            throws Exception

Throws:

Exception

after

public void after()
           throws Exception

Throws:

Exception

testConsistency

public void testConsistency()
                     throws IOException

Fat method where we start with a fat hbase:meta and then gradually intro problems running catalogjanitor for each to ensure it triggers complaint. Do one big method because takes a while to build up the context we need. We create three tables and then make holes, overlaps, add unknown servers and empty out regioninfo columns. Each should up counts in the CatalogJanitor.Report produced.

Throws:

IOException

incrementRow

private static byte[] incrementRow(byte[] row)

Take last byte and add one to it.

testHoles

public void testHoles()
               throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

fixHoles

private void fixHoles(org.apache.hadoop.hbase.master.janitor.CatalogJanitor janitor)
               throws IOException

Throws:

IOException

verifyMiddleHole

private void verifyMiddleHole(org.apache.hadoop.hbase.master.janitor.CatalogJanitor janitor)
                       throws IOException

Throws:

IOException

verifyCornerHoles

private void verifyCornerHoles(org.apache.hadoop.hbase.master.janitor.CatalogJanitor janitor,
 org.apache.hadoop.hbase.TableName tableName)
                        throws IOException

Throws:

IOException

getHoles

private LinkedList<org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.hbase.client.RegionInfo,org.apache.hadoop.hbase.client.RegionInfo>> getHoles(org.apache.hadoop.hbase.master.janitor.CatalogJanitor janitor,
 org.apache.hadoop.hbase.TableName tableName)
                                                                                                                                             throws IOException

Throws:

IOException

getRegionInfo

private org.apache.hadoop.hbase.client.RegionInfo getRegionInfo(org.apache.hadoop.hbase.TableName tableName,
 byte[] row)
                                                         throws IOException

Throws:

IOException

disableTable

private void disableTable(org.apache.hadoop.hbase.TableName tableName)
                   throws IOException,
InterruptedException

Throws:

IOException

InterruptedException