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

Class TestStripeCompactor

java.lang.Object

org.apache.hadoop.hbase.regionserver.compactions.TestStripeCompactor

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

Field Summary

Fields

Modifier and Type	Field	Description
private static final byte[]	KEY_B
private static final byte[]	KEY_C
private static final byte[]	KEY_D
private static final org.apache.hadoop.hbase.KeyValue	KV_A
private static final org.apache.hadoop.hbase.KeyValue	KV_B
private static final org.apache.hadoop.hbase.KeyValue	KV_C
private static final org.apache.hadoop.hbase.KeyValue	KV_D
private static final byte[]	NAME_OF_THINGS
private static final org.apache.hadoop.hbase.TableName	TABLE_NAME
private final boolean	usePrivateReaders

Constructor Summary

Constructors

Constructor	Description
TestStripeCompactor(boolean usePrivateReaders)

Method Summary

Modifier and Type	Method	Description
private static <T> T[]	a(T... a)
private org.apache.hadoop.hbase.regionserver.compactions.StripeCompactor	createCompactor(TestCompactor.StoreFileWritersCapture writers, org.apache.hadoop.hbase.KeyValue[] input)
private static org.apache.hadoop.hbase.KeyValue[]	e()
private static org.apache.hadoop.hbase.KeyValue	kvAfter(byte[] key)
static Stream<org.junit.jupiter.params.provider.Arguments>	parameters()
void	testBoundaryCompactionEmptyFiles()
void	testBoundaryCompactions()
void	testSizeCompactions()
private void	verifyBoundaryCompaction(org.apache.hadoop.hbase.KeyValue[] input, byte[][] boundaries, org.apache.hadoop.hbase.KeyValue[][] output)
private void	verifyBoundaryCompaction(org.apache.hadoop.hbase.KeyValue[] input, byte[][] boundaries, org.apache.hadoop.hbase.KeyValue[][] output, byte[] majorFrom, byte[] majorTo, boolean allFiles)
private void	verifySizeCompaction(org.apache.hadoop.hbase.KeyValue[] input, int targetCount, long targetSize, byte[] left, byte[] right, org.apache.hadoop.hbase.KeyValue[][] output)

Methods inherited from class java.lang.Object

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

Field Details

NAME_OF_THINGS

private static final byte[] NAME_OF_THINGS

TABLE_NAME

private static final org.apache.hadoop.hbase.TableName TABLE_NAME

KEY_B

private static final byte[] KEY_B

KEY_C

private static final byte[] KEY_C

KEY_D

private static final byte[] KEY_D

KV_A

private static final org.apache.hadoop.hbase.KeyValue KV_A

KV_B

private static final org.apache.hadoop.hbase.KeyValue KV_B

KV_C

private static final org.apache.hadoop.hbase.KeyValue KV_C

KV_D

private static final org.apache.hadoop.hbase.KeyValue KV_D

usePrivateReaders

private final boolean usePrivateReaders

Constructor Details

TestStripeCompactor

public TestStripeCompactor(boolean usePrivateReaders)

Method Details

parameters

public static Stream<org.junit.jupiter.params.provider.Arguments> parameters()

kvAfter

private static org.apache.hadoop.hbase.KeyValue kvAfter(byte[] key)

a

private static <T> T[] a(T... a)

e

private static org.apache.hadoop.hbase.KeyValue[] e()

testBoundaryCompactions

@TestTemplate
public void testBoundaryCompactions()
                             throws Exception

Throws:

Exception

testBoundaryCompactionEmptyFiles

@TestTemplate
public void testBoundaryCompactionEmptyFiles()
                                      throws Exception

Throws:

Exception

verifyBoundaryCompaction

private void verifyBoundaryCompaction(org.apache.hadoop.hbase.KeyValue[] input,
 byte[][] boundaries,
 org.apache.hadoop.hbase.KeyValue[][] output)
                               throws Exception

Throws:

Exception

verifyBoundaryCompaction

private void verifyBoundaryCompaction(org.apache.hadoop.hbase.KeyValue[] input,
 byte[][] boundaries,
 org.apache.hadoop.hbase.KeyValue[][] output,
 byte[] majorFrom,
 byte[] majorTo,
 boolean allFiles)
                               throws Exception

Throws:

Exception

testSizeCompactions

@TestTemplate
public void testSizeCompactions()
                         throws Exception

Throws:

Exception

verifySizeCompaction

private void verifySizeCompaction(org.apache.hadoop.hbase.KeyValue[] input,
 int targetCount,
 long targetSize,
 byte[] left,
 byte[] right,
 org.apache.hadoop.hbase.KeyValue[][] output)
                           throws Exception

Throws:

Exception

createCompactor

private org.apache.hadoop.hbase.regionserver.compactions.StripeCompactor createCompactor(TestCompactor.StoreFileWritersCapture writers,
 org.apache.hadoop.hbase.KeyValue[] input)
                                                                                  throws Exception

Throws:

Exception