org.apache.hadoop.hbase.util

Class TestRegionSplitter

java.lang.Object

org.apache.hadoop.hbase.util.TestRegionSplitter

public class TestRegionSplitter
extends Object

Tests for RegionSplitter, which can create a pre-split table or do a rolling split of an existing table.

Field Summary

Fields

Modifier and Type	Field and Description
private static String	CF_NAME
static HBaseClassTestRule	CLASS_RULE
private static org.slf4j.Logger	LOG
org.junit.rules.TestName	name
private static HBaseTestingUtility	UTIL
private static byte	xFF

Constructor Summary

Constructors

Constructor and Description
TestRegionSplitter()

Method Summary

Modifier and Type	Method and Description
private static int	indexOfBytes(List<byte[]> list, byte[] compareTo) List.indexOf() doesn't really work for a List<byte[]>, because byte[] doesn't override equals().
void	noopRollingSplit()
private void	preSplitTableAndVerify(List<byte[]> expectedBounds, String splitClass, org.apache.hadoop.hbase.TableName tableName) Creates a pre-split table with expectedBounds.size()+1 regions, then verifies that the region boundaries are the same as the expected region boundaries in expectedBounds.
private void	rollingSplitAndVerify(org.apache.hadoop.hbase.TableName tableName, String splitClass, List<byte[]> expectedBounds)
static void	setup()
private boolean	splitFailsPrecondition(org.apache.hadoop.hbase.util.RegionSplitter.SplitAlgorithm algo)
private boolean	splitFailsPrecondition(org.apache.hadoop.hbase.util.RegionSplitter.SplitAlgorithm algo, int numRegions)
private boolean	splitFailsPrecondition(org.apache.hadoop.hbase.util.RegionSplitter.SplitAlgorithm algo, String firstRow, String lastRow)
private boolean	splitFailsPrecondition(org.apache.hadoop.hbase.util.RegionSplitter.SplitAlgorithm algo, String firstRow, String lastRow, int numRegions)
static void	teardown()
void	testCreatePresplitTableHex() Test creating a pre-split table using the HexStringSplit algorithm.
void	testCreatePresplitTableUniform() Test creating a pre-split table using the UniformSplit algorithm.
void	testUserInput()
void	unitTestDecimalStringSplit() Unit tests for the DecimalStringSplit algorithm.
void	unitTestHexStringSplit() Unit tests for the HexStringSplit algorithm.
void	unitTestUniformSplit() Unit tests for the UniformSplit algorithm.
private void	verifyBounds(List<byte[]> expectedBounds, org.apache.hadoop.hbase.TableName tableName)

Methods inherited from class java.lang.Object

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

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

UTIL

private static final HBaseTestingUtility UTIL

CF_NAME

private static final String CF_NAME

See Also:

Constant Field Values

xFF

private static final byte xFF

See Also:

Constant Field Values

name

public org.junit.rules.TestName name

Constructor Detail

TestRegionSplitter

public TestRegionSplitter()

Method Detail

setup

public static void setup()
                  throws Exception

Throws:

Exception

teardown

public static void teardown()
                     throws Exception

Throws:

Exception

testCreatePresplitTableHex

public void testCreatePresplitTableHex()
                                throws Exception

Test creating a pre-split table using the HexStringSplit algorithm.

Throws:

Exception

testCreatePresplitTableUniform

public void testCreatePresplitTableUniform()
                                    throws Exception

Test creating a pre-split table using the UniformSplit algorithm.

Throws:

Exception

unitTestHexStringSplit

public void unitTestHexStringSplit()

Unit tests for the HexStringSplit algorithm. Makes sure it divides up the space of keys in the way that we expect.

unitTestDecimalStringSplit

public void unitTestDecimalStringSplit()

Unit tests for the DecimalStringSplit algorithm. Makes sure it divides up the space of keys in the way that we expect.

unitTestUniformSplit

public void unitTestUniformSplit()

Unit tests for the UniformSplit algorithm. Makes sure it divides up the space of keys in the way that we expect.

testUserInput

public void testUserInput()

splitFailsPrecondition

private boolean splitFailsPrecondition(org.apache.hadoop.hbase.util.RegionSplitter.SplitAlgorithm algo)

splitFailsPrecondition

private boolean splitFailsPrecondition(org.apache.hadoop.hbase.util.RegionSplitter.SplitAlgorithm algo,
                                       String firstRow,
                                       String lastRow)

splitFailsPrecondition

private boolean splitFailsPrecondition(org.apache.hadoop.hbase.util.RegionSplitter.SplitAlgorithm algo,
                                       String firstRow,
                                       String lastRow,
                                       int numRegions)

splitFailsPrecondition

private boolean splitFailsPrecondition(org.apache.hadoop.hbase.util.RegionSplitter.SplitAlgorithm algo,
                                       int numRegions)

preSplitTableAndVerify

private void preSplitTableAndVerify(List<byte[]> expectedBounds,
                                    String splitClass,
                                    org.apache.hadoop.hbase.TableName tableName)
                             throws Exception

Creates a pre-split table with expectedBounds.size()+1 regions, then verifies that the region boundaries are the same as the expected region boundaries in expectedBounds.

Throws:

Various - junit assertions

Exception

noopRollingSplit

public void noopRollingSplit()
                      throws Exception

Throws:

Exception

rollingSplitAndVerify

private void rollingSplitAndVerify(org.apache.hadoop.hbase.TableName tableName,
                                   String splitClass,
                                   List<byte[]> expectedBounds)
                            throws Exception

Throws:

Exception

verifyBounds

private void verifyBounds(List<byte[]> expectedBounds,
                          org.apache.hadoop.hbase.TableName tableName)
                   throws Exception

Throws:

Exception

indexOfBytes

private static int indexOfBytes(List<byte[]> list,
                                byte[] compareTo)

List.indexOf() doesn't really work for a List<byte[]>, because byte[] doesn't override equals(). This method checks whether a list contains a given element by checking each element using the byte array comparator.

Returns:

the index of the first element that equals compareTo, or -1 if no elements are equal.