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 and Description
private static class	TestStoreScannerClosure.ExtendedStoreScanner

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
TestStoreScannerClosure()

Method Summary

Modifier and Type	Method and 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.fs.Path storeFilePath, org.apache.hadoop.conf.Configuration conf)
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 Detail

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 HBaseTestingUtility TEST_UTIL

ROOT_DIR

private static String ROOT_DIR

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 Detail

TestStoreScannerClosure

public TestStoreScannerClosure()

Method Detail

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.fs.Path storeFilePath,
                                                                      org.apache.hadoop.conf.Configuration conf)
                                                               throws Exception

Throws:

Exception

testScannerCloseAndUpdateReaderInternal

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

Throws:

IOException

InterruptedException

getCols

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