org.apache.hadoop.hbase.regionserver

Class TestEndToEndSplitTransaction

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestEndToEndSplitTransaction

public class TestEndToEndSplitTransaction
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	TestEndToEndSplitTransaction.RegionChecker Checks regions using MetaTableAccessor and HTable methods
(package private) static class	TestEndToEndSplitTransaction.RegionSplitter

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static org.apache.hadoop.conf.Configuration	CONF
private static org.slf4j.Logger	LOG
org.junit.rules.TestName	name
private static HBaseTestingUtility	TEST_UTIL

Constructor Summary

Constructors

Constructor and Description
TestEndToEndSplitTransaction()

Method Summary

Modifier and Type	Method and Description
static void	afterAllTests()
static void	beforeAllTests()
static void	blockUntilRegionIsInMeta(org.apache.hadoop.hbase.client.Connection conn, long timeout, org.apache.hadoop.hbase.client.RegionInfo hri)
static void	blockUntilRegionIsOpened(org.apache.hadoop.conf.Configuration conf, long timeout, org.apache.hadoop.hbase.client.RegionInfo hri)
static void	blockUntilRegionSplit(org.apache.hadoop.conf.Configuration conf, long timeout, byte[] regionName, boolean waitForDaughters) Blocks until the region split is complete in hbase:meta and region server opens the daughters
static void	compactAndBlockUntilDone(org.apache.hadoop.hbase.client.Admin admin, org.apache.hadoop.hbase.regionserver.HRegionServer rs, byte[] regionName)
static void	flushAndBlockUntilDone(org.apache.hadoop.hbase.client.Admin admin, org.apache.hadoop.hbase.regionserver.HRegionServer rs, byte[] regionName)
static void	log(String msg)
static void	removeCompactedFiles(org.apache.hadoop.hbase.client.Connection conn, long timeout, org.apache.hadoop.hbase.client.RegionInfo hri)
void	testCanSplitJustAfterASplit() This is the test for : HBASE-20940 This test will split the region and try to open an reference over store file.
void	testFromClientSideWhileSplitting() Tests that the client sees meta table changes as atomic during splits

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

TEST_UTIL

private static final HBaseTestingUtility TEST_UTIL

CONF

private static final org.apache.hadoop.conf.Configuration CONF

name

public org.junit.rules.TestName name

Constructor Detail

TestEndToEndSplitTransaction

public TestEndToEndSplitTransaction()

Method Detail

beforeAllTests

public static void beforeAllTests()
                           throws Exception

Throws:

Exception

afterAllTests

public static void afterAllTests()
                          throws Exception

Throws:

Exception

testCanSplitJustAfterASplit

public void testCanSplitJustAfterASplit()
                                 throws Exception

This is the test for : HBASE-20940 This test will split the region and try to open an reference over store file. Once store file has any reference, it makes sure that region can't be split

Throws:

Exception

testFromClientSideWhileSplitting

public void testFromClientSideWhileSplitting()
                                      throws Throwable

Tests that the client sees meta table changes as atomic during splits

Throws:

Throwable

log

public static void log(String msg)

flushAndBlockUntilDone

public static void flushAndBlockUntilDone(org.apache.hadoop.hbase.client.Admin admin,
                                          org.apache.hadoop.hbase.regionserver.HRegionServer rs,
                                          byte[] regionName)
                                   throws IOException,
                                          InterruptedException

Throws:

IOException

InterruptedException

compactAndBlockUntilDone

public static void compactAndBlockUntilDone(org.apache.hadoop.hbase.client.Admin admin,
                                            org.apache.hadoop.hbase.regionserver.HRegionServer rs,
                                            byte[] regionName)
                                     throws IOException,
                                            InterruptedException

Throws:

IOException

InterruptedException

blockUntilRegionSplit

public static void blockUntilRegionSplit(org.apache.hadoop.conf.Configuration conf,
                                         long timeout,
                                         byte[] regionName,
                                         boolean waitForDaughters)
                                  throws IOException,
                                         InterruptedException

Blocks until the region split is complete in hbase:meta and region server opens the daughters

Throws:

IOException

InterruptedException

removeCompactedFiles

public static void removeCompactedFiles(org.apache.hadoop.hbase.client.Connection conn,
                                        long timeout,
                                        org.apache.hadoop.hbase.client.RegionInfo hri)
                                 throws IOException,
                                        InterruptedException

Throws:

IOException

InterruptedException

blockUntilRegionIsInMeta

public static void blockUntilRegionIsInMeta(org.apache.hadoop.hbase.client.Connection conn,
                                            long timeout,
                                            org.apache.hadoop.hbase.client.RegionInfo hri)
                                     throws IOException,
                                            InterruptedException

Throws:

IOException

InterruptedException

blockUntilRegionIsOpened

public static void blockUntilRegionIsOpened(org.apache.hadoop.conf.Configuration conf,
                                            long timeout,
                                            org.apache.hadoop.hbase.client.RegionInfo hri)
                                     throws IOException,
                                            InterruptedException

Throws:

IOException

InterruptedException