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 and Description
private static class	TestCompactedHFilesDischarger.ScanThread

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
TestCompactedHFilesDischarger()

Method Summary

Modifier and Type	Method and 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 Detail

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 Detail

TestCompactedHFilesDischarger

public TestCompactedHFilesDischarger()

Method Detail

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