Package org.apache.hadoop.hbase.regionserver

Class TestStoreScannerClosure

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestStoreScannerClosure

public class TestStoreScannerClosure
extends Object

This test tests whether parallel StoreScanner.close() and StoreScanner.updateReaders(List, List) works perfectly ensuring that there are no references on the existing Storescanner readers.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	TestStoreScannerClosure.ExtendedStoreScanner

Field Summary

Fields

Modifier and Type	Field	Description
private static org.apache.hadoop.hbase.io.hfile.CacheConfig	cacheConf
private static final byte[]	CF
private static final String	CF_STR
static final HBaseClassTestRule	CLASS_RULE
(package private) static org.apache.hadoop.conf.Configuration	CONF
private static final byte[]	fam
private static org.apache.hadoop.fs.FileSystem	fs
private static final org.apache.hadoop.hbase.KeyValue[]	kvs
private static final org.slf4j.Logger	LOG
org.junit.rules.TestName	name
private static final int	NUM_VALID_KEY_TYPES
private static org.apache.hadoop.hbase.regionserver.HRegion	region
private org.apache.hadoop.hbase.regionserver.ScanInfo	scanInfo
private static final HBaseTestingUtil	TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
TestStoreScannerClosure()

Method Summary

Modifier and Type	Method	Description
private static org.apache.hadoop.hbase.KeyValue.Type	generateKeyType(Random rand)
(package private) NavigableSet<byte[]>	getCols(String... strCols)
private org.apache.hadoop.hbase.regionserver.HStoreFile	readStoreFile(org.apache.hadoop.hbase.regionserver.StoreFileInfo fileinfo)
static void	setUp()
private void	testScannerCloseAndUpdateReaderInternal(boolean awaitUpdate, boolean awaitClose)
void	testScannerCloseAndUpdateReaders1()
void	testScannerCloseAndUpdateReaders2()
void	testScannerCloseAndUpdateReadersWithMemstoreScanner()
private org.apache.hadoop.fs.Path	writeStoreFile()

Methods inherited from class java.lang.Object

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

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

NUM_VALID_KEY_TYPES

private static final int NUM_VALID_KEY_TYPES

name

public org.junit.rules.TestName name

CF_STR

private static final String CF_STR

See Also:

• Constant Field Values

region

private static org.apache.hadoop.hbase.regionserver.HRegion region

CF

private static final byte[] CF

CONF

static org.apache.hadoop.conf.Configuration CONF

cacheConf

private static org.apache.hadoop.hbase.io.hfile.CacheConfig cacheConf

fs

private static org.apache.hadoop.fs.FileSystem fs

TEST_UTIL

private static final HBaseTestingUtil TEST_UTIL

scanInfo

private org.apache.hadoop.hbase.regionserver.ScanInfo scanInfo

fam

private static final byte[] fam

kvs

private static final org.apache.hadoop.hbase.KeyValue[] kvs

Constructor Details

TestStoreScannerClosure

public TestStoreScannerClosure()

Method Details

setUp

public static void setUp()
                  throws Exception

Throws:

Exception

testScannerCloseAndUpdateReadersWithMemstoreScanner

public void testScannerCloseAndUpdateReadersWithMemstoreScanner()
                                                         throws Exception

Throws:

Exception

testScannerCloseAndUpdateReaders1

public void testScannerCloseAndUpdateReaders1()
                                       throws Exception

Throws:

Exception

testScannerCloseAndUpdateReaders2

public void testScannerCloseAndUpdateReaders2()
                                       throws Exception

Throws:

Exception

writeStoreFile

private org.apache.hadoop.fs.Path writeStoreFile()
                                          throws IOException

Throws:

IOException

generateKeyType

private static org.apache.hadoop.hbase.KeyValue.Type generateKeyType(Random rand)

readStoreFile

private org.apache.hadoop.hbase.regionserver.HStoreFile readStoreFile(org.apache.hadoop.hbase.regionserver.StoreFileInfo fileinfo)
                                                               throws Exception

Throws:

Exception

testScannerCloseAndUpdateReaderInternal

private void testScannerCloseAndUpdateReaderInternal(boolean awaitUpdate,
 boolean awaitClose)
                                              throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getCols

NavigableSet<byte[]> getCols(String... strCols)