Package org.apache.hadoop.hbase.regionserver.compactions

Class TestCompactedHFilesDischarger

java.lang.Object

org.apache.hadoop.hbase.regionserver.compactions.TestCompactedHFilesDischarger

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	TestCompactedHFilesDischarger.ScanThread

Field Summary

Fields

Modifier and Type	Field	Description
private static AtomicInteger	counter
private static final byte[]	fam
private static CountDownLatch	latch
private static final byte[]	qual1
private org.apache.hadoop.hbase.regionserver.HRegion	region
private org.apache.hadoop.hbase.regionserver.RegionServerServices	rss
private static AtomicInteger	scanCompletedCounter
private final HBaseTestingUtil	testUtil
private static final byte[]	val

Constructor Summary

Constructors

Constructor	Description
TestCompactedHFilesDischarger()

Method Summary

Modifier and Type	Method	Description
protected void	countDown()
void	setUp()
protected void	startScannerThreads()
void	tearDown()
void	testCleanerWithParallelScanners()
void	testCleanerWithParallelScannersAfterCompaction()
void	testCompactedHFilesCleaner()
void	testStoreFileMissing()
private void	write(String row1)

Methods inherited from class java.lang.Object

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

Field Details

testUtil

private final HBaseTestingUtil testUtil

region

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

fam

private static final byte[] fam

qual1

private static final byte[] qual1

val

private static final byte[] val

latch

private static CountDownLatch latch

counter

private static AtomicInteger counter

scanCompletedCounter

private static AtomicInteger scanCompletedCounter

rss

private org.apache.hadoop.hbase.regionserver.RegionServerServices rss

Constructor Details

TestCompactedHFilesDischarger

public TestCompactedHFilesDischarger()

Method Details

setUp

@BeforeEach
public void setUp()
           throws Exception

Throws:

Exception

tearDown

@AfterEach
public void tearDown()
              throws IOException

Throws:

IOException

testCompactedHFilesCleaner

@Test
public void testCompactedHFilesCleaner()
                                throws Exception

Throws:

Exception

testCleanerWithParallelScannersAfterCompaction

@Test
public void testCleanerWithParallelScannersAfterCompaction()
                                                    throws Exception

Throws:

Exception

testCleanerWithParallelScanners

@Test
public void testCleanerWithParallelScanners()
                                     throws Exception

Throws:

Exception

testStoreFileMissing

@Test
public void testStoreFileMissing()
                          throws Exception

Throws:

Exception

write

private void write(String row1)
            throws IOException

Throws:

IOException

countDown

protected void countDown()

startScannerThreads

protected void startScannerThreads()
                            throws InterruptedException

Throws:

InterruptedException