org.apache.hadoop.hbase.util.hbck

Class OfflineMetaRebuildTestCore

java.lang.Object

org.apache.hadoop.hbase.util.hbck.OfflineMetaRebuildTestCore

public class OfflineMetaRebuildTestCore
extends Object

This testing base class creates a minicluster and testing table table and shuts down the cluster afterwards. It also provides methods wipes out meta and to inject errors into meta and the file system. Tests should generally break stuff, then attempt to rebuild the meta table offline, then restart hbase, and finally perform checks. NOTE: This is a slow set of tests which takes ~30s each needs to run on a relatively beefy machine. It seems necessary to have each test in a new jvm since minicluster startup and tear downs seem to leak file handles and eventually cause out of file handle exceptions.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.hadoop.conf.Configuration	conf
protected org.apache.hadoop.hbase.client.Connection	connection
private static byte[]	FAM
protected org.apache.hadoop.hbase.client.Table	htbl
private static org.slf4j.Logger	LOG
protected static byte[][]	splits
protected org.apache.hadoop.hbase.TableName	table
private static String	TABLE_BASE
private static int	tableIdx
protected HBaseTestingUtility	TEST_UTIL

Constructor Summary

Constructors

Constructor and Description
OfflineMetaRebuildTestCore()

Method Summary

Modifier and Type	Method and Description
protected org.apache.hadoop.hbase.client.RegionInfo	createRegion(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.Table htbl, byte[] startKey, byte[] endKey)
protected void	deleteRegion(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.Table tbl, byte[] startKey, byte[] endKey)
private void	dumpMeta(org.apache.hadoop.hbase.HTableDescriptor htd)
protected org.apache.hadoop.hbase.HTableDescriptor[]	getTables(org.apache.hadoop.conf.Configuration configuration)
private void	populateTable(org.apache.hadoop.hbase.client.Table tbl)
protected int	scanMeta() Dumps hbase:meta table info
void	setUpBefore()
private org.apache.hadoop.hbase.client.Table	setupTable(org.apache.hadoop.hbase.TableName tablename) Setup a clean table before we start mucking with it.
protected int	tableRowCount(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.TableName table) Returns the number of rows in a given table.
void	tearDownAfter()
protected void	wipeOutMeta()

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

TEST_UTIL

protected HBaseTestingUtility TEST_UTIL

conf

protected org.apache.hadoop.conf.Configuration conf

FAM

private static final byte[] FAM

htbl

protected org.apache.hadoop.hbase.client.Table htbl

splits

protected static final byte[][] splits

TABLE_BASE

private static final String TABLE_BASE

See Also:

Constant Field Values

tableIdx

private static int tableIdx

table

protected org.apache.hadoop.hbase.TableName table

connection

protected org.apache.hadoop.hbase.client.Connection connection

Constructor Detail

OfflineMetaRebuildTestCore

public OfflineMetaRebuildTestCore()

Method Detail

setUpBefore

public void setUpBefore()
                 throws Exception

Throws:

Exception

tearDownAfter

public void tearDownAfter()
                   throws Exception

Throws:

Exception

setupTable

private org.apache.hadoop.hbase.client.Table setupTable(org.apache.hadoop.hbase.TableName tablename)
                                                 throws Exception

Setup a clean table before we start mucking with it.

Throws:

IOException

InterruptedException

org.apache.zookeeper.KeeperException

Exception

dumpMeta

private void dumpMeta(org.apache.hadoop.hbase.HTableDescriptor htd)
               throws IOException

Throws:

IOException

populateTable

private void populateTable(org.apache.hadoop.hbase.client.Table tbl)
                    throws IOException

Throws:

IOException

deleteRegion

protected void deleteRegion(org.apache.hadoop.conf.Configuration conf,
                            org.apache.hadoop.hbase.client.Table tbl,
                            byte[] startKey,
                            byte[] endKey)
                     throws IOException

Throws:

IOException

createRegion

protected org.apache.hadoop.hbase.client.RegionInfo createRegion(org.apache.hadoop.conf.Configuration conf,
                                                                 org.apache.hadoop.hbase.client.Table htbl,
                                                                 byte[] startKey,
                                                                 byte[] endKey)
                                                          throws IOException

Throws:

IOException

wipeOutMeta

protected void wipeOutMeta()
                    throws IOException

Throws:

IOException

tableRowCount

protected int tableRowCount(org.apache.hadoop.conf.Configuration conf,
                            org.apache.hadoop.hbase.TableName table)
                     throws IOException

Returns the number of rows in a given table. HBase must be up and the table should be present (will wait for timeout for a while otherwise)

Returns:

# of rows in the specified table

Throws:

IOException

scanMeta

protected int scanMeta()
                throws IOException

Dumps hbase:meta table info

Returns:

# of entries in meta.

Throws:

IOException

getTables

protected org.apache.hadoop.hbase.HTableDescriptor[] getTables(org.apache.hadoop.conf.Configuration configuration)
                                                        throws IOException

Throws:

IOException