Package org.apache.hadoop.hbase.mob

Class TestMobCompactionWithException

java.lang.Object

org.apache.hadoop.hbase.mob.TestMobCompactionWithException

@Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
public class TestMobCompactionWithException
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestMobCompactionWithException.MyMobStoreCompactor

Field Summary

Fields

Modifier and Type	Field	Description
private static final byte[]	COLUMN_FAMILY
private org.apache.hadoop.hbase.client.ColumnFamilyDescriptor	columnFamilyDescriptor
private static org.apache.hadoop.conf.Configuration	conf
private org.apache.hadoop.fs.FileSystem	fs
private static final HBaseTestingUtil	HTU
(package private) static final org.slf4j.Logger	LOG
private org.apache.hadoop.hbase.regionserver.HRegion	region
private static int	rowCount
private final byte[]	STARTROW
private org.apache.hadoop.hbase.client.Table	table
private org.apache.hadoop.hbase.client.TableDescriptor	tableDescriptor
private static boolean	testException
private String	testMethodName

Constructor Summary

Constructors

Constructor	Description
TestMobCompactionWithException()

Method Summary

Modifier and Type	Method	Description
private int	countMobFiles()
private int	countStoreFiles()
private org.apache.hadoop.hbase.client.Put	createPut(int rowIdx, byte[] dummyData)
private void	createTable(long mobThreshold)
private long	getMobFileByteSize()
private byte[]	makeDummyData(int size)
static void	setUp()
void	setUp(org.junit.jupiter.api.TestInfo testInfo)
void	tearDown()
void	testMobStoreFileDeletedWhenCompactException()	This test is for HBASE-27433.

Methods inherited from class java.lang.Object

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

Field Details

LOG

static final org.slf4j.Logger LOG

HTU

private static final HBaseTestingUtil HTU

conf

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

testMethodName

private String testMethodName

region

private org.apache.hadoop.hbase.regionserver.HRegion region

tableDescriptor

private org.apache.hadoop.hbase.client.TableDescriptor tableDescriptor

columnFamilyDescriptor

private org.apache.hadoop.hbase.client.ColumnFamilyDescriptor columnFamilyDescriptor

fs

private org.apache.hadoop.fs.FileSystem fs

COLUMN_FAMILY

private static final byte[] COLUMN_FAMILY

STARTROW

private final byte[] STARTROW

testException

private static volatile boolean testException

rowCount

private static int rowCount

table

private org.apache.hadoop.hbase.client.Table table

Constructor Details

TestMobCompactionWithException

public TestMobCompactionWithException()

Method Details

setUp

@BeforeAll
public static void setUp()
                  throws Exception

Throws:

Exception

setUp

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

tearDown

@AfterEach
public void tearDown()
              throws Exception

Throws:

Exception

createTable

private void createTable(long mobThreshold)
                  throws IOException

Throws:

IOException

testMobStoreFileDeletedWhenCompactException

@Test
public void testMobStoreFileDeletedWhenCompactException()
                                                 throws Exception

This test is for HBASE-27433.

Throws:

Exception

countStoreFiles

private int countStoreFiles()
                     throws IOException

Throws:

IOException

countMobFiles

private int countMobFiles()
                   throws IOException

Throws:

IOException

getMobFileByteSize

private long getMobFileByteSize()
                         throws IOException

Throws:

IOException

createPut

private org.apache.hadoop.hbase.client.Put createPut(int rowIdx,
 byte[] dummyData)
                                              throws IOException

Throws:

IOException

makeDummyData

private byte[] makeDummyData(int size)