Package org.apache.hadoop.hbase.regionserver

Class TestCompactionWithShippingCoprocessor

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestCompactionWithShippingCoprocessor

@Tag("org.apache.hadoop.hbase.testclassification.MediumTests") @Tag("org.apache.hadoop.hbase.testclassification.CoprocessorTests")
public class TestCompactionWithShippingCoprocessor
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestCompactionWithShippingCoprocessor.CompactionObserver
static class	TestCompactionWithShippingCoprocessor.ShippedObservingScanner

Field Summary

Fields

Modifier and Type	Field	Description
private static final byte[]	FAMILY
private String	name
private static final AtomicInteger	SHIPPED_COUNT
protected static final HBaseTestingUtil	TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
TestCompactionWithShippingCoprocessor()

Method Summary

Modifier and Type	Method	Description
void	setTestName(org.junit.jupiter.api.TestInfo testInfo)
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testCoprocScannersExtendingShipperGetShipped()	Verifies that if a coproc returns an InternalScanner which implements Shipper, the shippped method is appropriately called in Compactor.

Methods inherited from class java.lang.Object

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

Field Details

SHIPPED_COUNT

private static final AtomicInteger SHIPPED_COUNT

TEST_UTIL

protected static final HBaseTestingUtil TEST_UTIL

FAMILY

private static final byte[] FAMILY

name

private String name

Constructor Details

TestCompactionWithShippingCoprocessor

public TestCompactionWithShippingCoprocessor()

Method Details

setTestName

@BeforeEach
public void setTestName(org.junit.jupiter.api.TestInfo testInfo)

setUpBeforeClass

@BeforeAll
public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

@AfterAll
public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

testCoprocScannersExtendingShipperGetShipped

@Test
public void testCoprocScannersExtendingShipperGetShipped()
                                                  throws Exception

Verifies that if a coproc returns an InternalScanner which implements Shipper, the shippped method is appropriately called in Compactor.

Throws:

Exception