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

Class TestCompactedHFilesDischarger

java.lang.Object

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

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
static final HBaseClassTestRule	CLASS_RULE
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 HBaseTestingUtility	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

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

testUtil

private final HBaseTestingUtility 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

public void setUp()
           throws Exception

Throws:

Exception

tearDown

public void tearDown()
              throws IOException

Throws:

IOException

testCompactedHFilesCleaner

public void testCompactedHFilesCleaner()
                                throws Exception

Throws:

Exception

testCleanerWithParallelScannersAfterCompaction

public void testCleanerWithParallelScannersAfterCompaction()
                                                    throws Exception

Throws:

Exception

testCleanerWithParallelScanners

public void testCleanerWithParallelScanners()
                                     throws Exception

Throws:

Exception

testStoreFileMissing

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