Package org.apache.hadoop.hbase.coprocessor

Class TestRegionObserverScannerOpenHook

java.lang.Object

org.apache.hadoop.hbase.coprocessor.TestRegionObserverScannerOpenHook

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestRegionObserverScannerOpenHook.CompactionCompletionNotifyingRegion
static class	TestRegionObserverScannerOpenHook.EmptyRegionObsever	Do the default logic in RegionObserver interface.
static class	TestRegionObserverScannerOpenHook.NoDataFilter
static class	TestRegionObserverScannerOpenHook.NoDataFromCompaction	Don't allow any data to be written out in the compaction by creating a custom StoreScanner.
static class	TestRegionObserverScannerOpenHook.NoDataFromFlush	Don't allow any data in a flush by creating a custom StoreScanner.
static class	TestRegionObserverScannerOpenHook.NoDataFromScan	Don't return any data from a scan by creating a custom StoreScanner.

Field Summary

Fields

Modifier and Type	Field	Description
private String	currentTestName
(package private) static final org.apache.hadoop.fs.Path	DIR
private static final org.apache.hadoop.hbase.regionserver.InternalScanner	NO_DATA
private static HBaseTestingUtil	UTIL

Constructor Summary

Constructors

Constructor	Description
TestRegionObserverScannerOpenHook()

Method Summary

Modifier and Type	Method	Description
(package private) org.apache.hadoop.hbase.regionserver.HRegion	initHRegion(byte[] tableName, String callingMethod, org.apache.hadoop.conf.Configuration conf, byte[]... families)
void	setUp(org.junit.jupiter.api.TestInfo testInfo)
void	testRegionObserverCompactionTimeStacking()	Unfortunately, the easiest way to test this is to spin up a mini-cluster since we want to do the usual compaction mechanism on the region, rather than going through the backdoor to the region
void	testRegionObserverFlushTimeStacking()
void	testRegionObserverScanTimeStacking()

Methods inherited from class java.lang.Object

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

Field Details

UTIL

private static HBaseTestingUtil UTIL

DIR

static final org.apache.hadoop.fs.Path DIR

currentTestName

private String currentTestName

NO_DATA

private static final org.apache.hadoop.hbase.regionserver.InternalScanner NO_DATA

Constructor Details

TestRegionObserverScannerOpenHook

public TestRegionObserverScannerOpenHook()

Method Details

setUp

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

initHRegion

org.apache.hadoop.hbase.regionserver.HRegion initHRegion(byte[] tableName,
 String callingMethod,
 org.apache.hadoop.conf.Configuration conf,
 byte[]... families)
                                                  throws IOException

Throws:

IOException

testRegionObserverScanTimeStacking

@Test
public void testRegionObserverScanTimeStacking()
                                        throws Exception

Throws:

Exception

testRegionObserverFlushTimeStacking

@Test
public void testRegionObserverFlushTimeStacking()
                                         throws Exception

Throws:

Exception

testRegionObserverCompactionTimeStacking

@Test
public void testRegionObserverCompactionTimeStacking()
                                              throws Exception

Unfortunately, the easiest way to test this is to spin up a mini-cluster since we want to do the usual compaction mechanism on the region, rather than going through the backdoor to the region

Throws:

Exception