Package org.apache.hadoop.hbase.regionserver

Class TestCompactionWithShippingCoprocessor

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestCompactionWithShippingCoprocessor

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
static final HBaseClassTestRule	CLASS_RULE
private static final byte[]	FAMILY
org.junit.rules.TestName	name
private static final AtomicInteger	SHIPPED_COUNT
private static final HBaseTestingUtility	TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
TestCompactionWithShippingCoprocessor()

Method Summary

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

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

TEST_UTIL

private static final HBaseTestingUtility TEST_UTIL

FAMILY

private static final byte[] FAMILY

name

public org.junit.rules.TestName name

Constructor Details

TestCompactionWithShippingCoprocessor

public TestCompactionWithShippingCoprocessor()

Method Details

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

testCoprocScannersExtendingShipperGetShipped

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