public class TestCatalogJanitorCluster extends Object
Modifier and Type | Field and Description |
---|---|
static HBaseClassTestRule |
CLASS_RULE |
private static org.slf4j.Logger |
LOG |
org.junit.rules.TestName |
name |
private static org.apache.hadoop.hbase.TableName |
T1 |
private static org.apache.hadoop.hbase.TableName |
T2 |
private static org.apache.hadoop.hbase.TableName |
T3 |
private static org.apache.hadoop.hbase.TableName |
T4 |
private static org.apache.hadoop.hbase.TableName |
T5 |
private static org.apache.hadoop.hbase.TableName |
T6 |
private static org.apache.hadoop.hbase.TableName |
T7 |
private static HBaseTestingUtil |
TEST_UTIL |
Constructor and Description |
---|
TestCatalogJanitorCluster() |
Modifier and Type | Method and 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) |
private static final org.slf4j.Logger LOG
public static final HBaseClassTestRule CLASS_RULE
public final org.junit.rules.TestName name
private static final HBaseTestingUtil TEST_UTIL
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
public TestCatalogJanitorCluster()
public void testConsistency() throws IOException
IOException
private static byte[] incrementRow(byte[] row)
public void testHoles() throws IOException, InterruptedException
IOException
InterruptedException
private void fixHoles(org.apache.hadoop.hbase.master.janitor.CatalogJanitor janitor) throws IOException
IOException
private void verifyMiddleHole(org.apache.hadoop.hbase.master.janitor.CatalogJanitor janitor) throws IOException
IOException
private void verifyCornerHoles(org.apache.hadoop.hbase.master.janitor.CatalogJanitor janitor, org.apache.hadoop.hbase.TableName tableName) throws IOException
IOException
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
IOException
private org.apache.hadoop.hbase.client.RegionInfo getRegionInfo(org.apache.hadoop.hbase.TableName tableName, byte[] row) throws IOException
IOException
private void disableTable(org.apache.hadoop.hbase.TableName tableName) throws IOException, InterruptedException
IOException
InterruptedException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.