public class TestStripeCompactionPolicy extends Object
| Modifier and Type | Field and Description |
|---|---|
boolean |
usePrivateReaders |
| Constructor and Description |
|---|
TestStripeCompactionPolicy() |
| Modifier and Type | Method and Description |
|---|---|
static Iterable<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.
|
public void testSingleStripeCompaction()
throws Exception
Exceptionpublic void testWithParallelCompaction()
throws Exception
Exceptionpublic void testExistingStripesFromL0()
throws Exception
Exceptionpublic void testNothingToCompactFromL0()
throws Exception
Exceptionpublic void testSplitOffStripeOffPeak()
throws Exception
Exceptionpublic void testSplitOffStripeDropDeletes()
throws Exception
Exceptionpublic void testSingleStripeDropDeletes()
throws Exception
Exceptionprotected void verifyFlush(StripeCompactionPolicy policy, StripeCompactionPolicy.StripeInformationProvider si, KeyValue[] input, KeyValue[][] expected, byte[][] boundaries) throws IOException
IOException