Package org.apache.hadoop.hbase.regionserver

Class TestEndToEndSplitTransaction

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestEndToEndSplitTransaction

@Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestEndToEndSplitTransaction
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	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	Description
private static final org.apache.hadoop.conf.Configuration	CONF
private static final org.slf4j.Logger	LOG
private String	name
private static final HBaseTestingUtil	TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
TestEndToEndSplitTransaction()

Method Summary

Modifier and Type	Method	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	setTestName(org.junit.jupiter.api.TestInfo testInfo)
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 Details

LOG

private static final org.slf4j.Logger LOG

TEST_UTIL

private static final HBaseTestingUtil TEST_UTIL

CONF

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

name

private String name

Constructor Details

TestEndToEndSplitTransaction

public TestEndToEndSplitTransaction()

Method Details

setTestName

@BeforeEach
public void setTestName(org.junit.jupiter.api.TestInfo testInfo)

beforeAllTests

@BeforeAll
public static void beforeAllTests()
                           throws Exception

Throws:

Exception

afterAllTests

@AfterAll
public static void afterAllTests()
                          throws Exception

Throws:

Exception

testCanSplitJustAfterASplit

@Test
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

@Test
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