org.apache.hadoop.hbase.regionserver.compactions

Class TestStripeCompactionPolicy

java.lang.Object

org.apache.hadoop.hbase.regionserver.compactions.TestStripeCompactionPolicy

public class TestStripeCompactionPolicy
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
boolean	usePrivateReaders

Constructor Summary

Constructors

Constructor and Description
TestStripeCompactionPolicy()

Method Summary

Modifier and Type	Method and Description
static java.lang.Iterable<java.lang.Object[]>	data()
void	testExistingStripesFromL0()
void	testInitialCountFromL0()
void	testMergeExpiredFiles()
void	testMergeExpiredStripes()
void	testNewStripesFromFlush()
void	testNoStripesFromFlush()
void	testNothingToCompactFromL0()
void	testOldStripesFromFlush()
void	testSingleStripeCompaction()
void	testSingleStripeDropDeletes()
void	testSplitOffStripe()
void	testSplitOffStripeDropDeletes()
void	testSplitOffStripeOffPeak()
void	testWithParallelCompaction()
void	testWithReferences()
protected void	verifyFlush(StripeCompactionPolicy policy, StripeCompactionPolicy.StripeInformationProvider si, KeyValue[] input, KeyValue[][] expected, byte[][] boundaries) Verify arbitrary flush.

Methods inherited from class java.lang.Object

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

Field Detail

usePrivateReaders

public boolean usePrivateReaders

Constructor Detail

TestStripeCompactionPolicy

public TestStripeCompactionPolicy()

Method Detail

data

public static java.lang.Iterable<java.lang.Object[]> data()

testNoStripesFromFlush

public void testNoStripesFromFlush()
                            throws java.lang.Exception

Throws:

java.lang.Exception

testOldStripesFromFlush

public void testOldStripesFromFlush()
                             throws java.lang.Exception

Throws:

java.lang.Exception

testNewStripesFromFlush

public void testNewStripesFromFlush()
                             throws java.lang.Exception

Throws:

java.lang.Exception

testSingleStripeCompaction

public void testSingleStripeCompaction()
                                throws java.lang.Exception

Throws:

java.lang.Exception

testWithParallelCompaction

public void testWithParallelCompaction()
                                throws java.lang.Exception

Throws:

java.lang.Exception

testWithReferences

public void testWithReferences()
                        throws java.lang.Exception

Throws:

java.lang.Exception

testInitialCountFromL0

public void testInitialCountFromL0()
                            throws java.lang.Exception

Throws:

java.lang.Exception

testExistingStripesFromL0

public void testExistingStripesFromL0()
                               throws java.lang.Exception

Throws:

java.lang.Exception

testNothingToCompactFromL0

public void testNothingToCompactFromL0()
                                throws java.lang.Exception

Throws:

java.lang.Exception

testSplitOffStripe

public void testSplitOffStripe()
                        throws java.lang.Exception

Throws:

java.lang.Exception

testSplitOffStripeOffPeak

public void testSplitOffStripeOffPeak()
                               throws java.lang.Exception

Throws:

java.lang.Exception

testSplitOffStripeDropDeletes

public void testSplitOffStripeDropDeletes()
                                   throws java.lang.Exception

Throws:

java.lang.Exception

testMergeExpiredFiles

public void testMergeExpiredFiles()
                           throws java.lang.Exception

Throws:

java.lang.Exception

testMergeExpiredStripes

public void testMergeExpiredStripes()
                             throws java.lang.Exception

Throws:

java.lang.Exception

testSingleStripeDropDeletes

public void testSingleStripeDropDeletes()
                                 throws java.lang.Exception

Throws:

java.lang.Exception

verifyFlush

protected void verifyFlush(StripeCompactionPolicy policy,
                           StripeCompactionPolicy.StripeInformationProvider si,
                           KeyValue[] input,
                           KeyValue[][] expected,
                           byte[][] boundaries)
                    throws java.io.IOException

Verify arbitrary flush.

Throws:

java.io.IOException