org.apache.hadoop.hbase.client

Class TestBlockEvictionFromClient

java.lang.Object

org.apache.hadoop.hbase.client.TestBlockEvictionFromClient

public class TestBlockEvictionFromClient
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestBlockEvictionFromClient.CustomInnerRegionObserver
static class	TestBlockEvictionFromClient.CustomInnerRegionObserverWrapper
private static class	TestBlockEvictionFromClient.CustomScanner
private static class	TestBlockEvictionFromClient.GetThread
private static class	TestBlockEvictionFromClient.MultiGetThread
private static class	TestBlockEvictionFromClient.ScanThread

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static CountDownLatch	compactionLatch
private static byte[]	data
private static byte[]	data2
private static CountDownLatch	exceptionLatch
private static byte[][]	FAMILIES_1
private static byte[]	FAMILY
private static CountDownLatch	getLatch
private static CountDownLatch	latch
private static org.slf4j.Logger	LOG
org.junit.rules.TestName	name
private static int	NO_OF_THREADS
private static byte[]	QUALIFIER
private static byte[]	QUALIFIER2
private static byte[]	ROW
private static byte[]	ROW1
private static byte[]	ROW2
private static byte[]	ROW3
(package private) static byte[][]	ROWS
protected static int	SLAVES
protected static HBaseTestingUtility	TEST_UTIL

Constructor Summary

Constructors

Constructor and Description
TestBlockEvictionFromClient()

Method Summary

Modifier and Type	Method and Description
private void	checkForBlockEviction(org.apache.hadoop.hbase.io.hfile.BlockCache cache, boolean getClosed, boolean expectOnlyZero)
private TestBlockEvictionFromClient.GetThread[]	initiateGet(org.apache.hadoop.hbase.client.Table table, boolean tracker, boolean multipleCFs)
private TestBlockEvictionFromClient.MultiGetThread[]	initiateMultiGet(org.apache.hadoop.hbase.client.Table table)
private TestBlockEvictionFromClient.ScanThread[]	initiateScan(org.apache.hadoop.hbase.client.Table table, boolean reverse)
private void	insertData(org.apache.hadoop.hbase.client.Table table)
private void	iterateBlockCache(org.apache.hadoop.hbase.io.hfile.BlockCache cache, Iterator<org.apache.hadoop.hbase.io.hfile.CachedBlock> iterator)
private org.apache.hadoop.hbase.io.hfile.BlockCache	setCacheProperties(org.apache.hadoop.hbase.regionserver.HRegion region)
void	setUp()
static void	setUpBeforeClass()
void	tearDown()
static void	tearDownAfterClass()
void	testBlockEvictionAfterHBASE13082WithCompactionAndFlush()
void	testBlockEvictionWithParallelScans()
void	testBlockRefCountAfterSplits()
void	testGetsWithMultiColumnsAndExplicitTracker()
void	testGetWithCellsInDifferentFiles()
void	testGetWithMultipleColumnFamilies()
void	testMultiGets()
void	testParallelGetsAndScans()
void	testParallelGetsAndScanWithWrappedRegionScanner()
void	testReverseScanWithCompaction()
void	testScanWithCompaction()
private void	testScanWithCompactionInternals(String tableNameStr, boolean reversed)
void	testScanWithException()
void	testScanWithMultipleColumnFamilies()
private void	waitForStoreFileCount(org.apache.hadoop.hbase.regionserver.HStore store, int count, int timeout)

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

TEST_UTIL

protected static final HBaseTestingUtility TEST_UTIL

ROWS

static byte[][] ROWS

NO_OF_THREADS

private static int NO_OF_THREADS

ROW

private static byte[] ROW

ROW1

private static byte[] ROW1

ROW2

private static byte[] ROW2

ROW3

private static byte[] ROW3

FAMILY

private static byte[] FAMILY

FAMILIES_1

private static byte[][] FAMILIES_1

QUALIFIER

private static byte[] QUALIFIER

QUALIFIER2

private static byte[] QUALIFIER2

data

private static byte[] data

data2

private static byte[] data2

SLAVES

protected static int SLAVES

latch

private static CountDownLatch latch

getLatch

private static CountDownLatch getLatch

compactionLatch

private static CountDownLatch compactionLatch

exceptionLatch

private static CountDownLatch exceptionLatch

name

public org.junit.rules.TestName name

Constructor Detail

TestBlockEvictionFromClient

public TestBlockEvictionFromClient()

Method Detail

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

setUp

public void setUp()
           throws Exception

Throws:

Exception

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

testBlockEvictionWithParallelScans

public void testBlockEvictionWithParallelScans()
                                        throws Exception

Throws:

Exception

testParallelGetsAndScans

public void testParallelGetsAndScans()
                              throws IOException,
                                     InterruptedException

Throws:

IOException

InterruptedException

testGetWithCellsInDifferentFiles

public void testGetWithCellsInDifferentFiles()
                                      throws IOException,
                                             InterruptedException

Throws:

IOException

InterruptedException

testGetsWithMultiColumnsAndExplicitTracker

public void testGetsWithMultiColumnsAndExplicitTracker()
                                                throws IOException,
                                                       InterruptedException

Throws:

IOException

InterruptedException

testGetWithMultipleColumnFamilies

public void testGetWithMultipleColumnFamilies()
                                       throws IOException,
                                              InterruptedException

Throws:

IOException

InterruptedException

testBlockRefCountAfterSplits

public void testBlockRefCountAfterSplits()
                                  throws IOException,
                                         InterruptedException

Throws:

IOException

InterruptedException

testMultiGets

public void testMultiGets()
                   throws IOException,
                          InterruptedException

Throws:

IOException

InterruptedException

testScanWithMultipleColumnFamilies

public void testScanWithMultipleColumnFamilies()
                                        throws IOException,
                                               InterruptedException

Throws:

IOException

InterruptedException

setCacheProperties

private org.apache.hadoop.hbase.io.hfile.BlockCache setCacheProperties(org.apache.hadoop.hbase.regionserver.HRegion region)

testParallelGetsAndScanWithWrappedRegionScanner

public void testParallelGetsAndScanWithWrappedRegionScanner()
                                                     throws IOException,
                                                            InterruptedException

Throws:

IOException

InterruptedException

testScanWithCompaction

public void testScanWithCompaction()
                            throws IOException,
                                   InterruptedException

Throws:

IOException

InterruptedException

testReverseScanWithCompaction

public void testReverseScanWithCompaction()
                                   throws IOException,
                                          InterruptedException

Throws:

IOException

InterruptedException

testScanWithCompactionInternals

private void testScanWithCompactionInternals(String tableNameStr,
                                             boolean reversed)
                                      throws IOException,
                                             InterruptedException

Throws:

IOException

InterruptedException

testBlockEvictionAfterHBASE13082WithCompactionAndFlush

public void testBlockEvictionAfterHBASE13082WithCompactionAndFlush()
                                                            throws IOException,
                                                                   InterruptedException

Throws:

IOException

InterruptedException

testScanWithException

public void testScanWithException()
                           throws IOException,
                                  InterruptedException

Throws:

IOException

InterruptedException

iterateBlockCache

private void iterateBlockCache(org.apache.hadoop.hbase.io.hfile.BlockCache cache,
                               Iterator<org.apache.hadoop.hbase.io.hfile.CachedBlock> iterator)

insertData

private void insertData(org.apache.hadoop.hbase.client.Table table)
                 throws IOException

Throws:

IOException

initiateScan

private TestBlockEvictionFromClient.ScanThread[] initiateScan(org.apache.hadoop.hbase.client.Table table,
                                                              boolean reverse)
                                                       throws IOException,
                                                              InterruptedException

Throws:

IOException

InterruptedException

initiateGet

private TestBlockEvictionFromClient.GetThread[] initiateGet(org.apache.hadoop.hbase.client.Table table,
                                                            boolean tracker,
                                                            boolean multipleCFs)
                                                     throws IOException,
                                                            InterruptedException

Throws:

IOException

InterruptedException

initiateMultiGet

private TestBlockEvictionFromClient.MultiGetThread[] initiateMultiGet(org.apache.hadoop.hbase.client.Table table)
                                                               throws IOException,
                                                                      InterruptedException

Throws:

IOException

InterruptedException

checkForBlockEviction

private void checkForBlockEviction(org.apache.hadoop.hbase.io.hfile.BlockCache cache,
                                   boolean getClosed,
                                   boolean expectOnlyZero)
                            throws InterruptedException

Throws:

InterruptedException

waitForStoreFileCount

private void waitForStoreFileCount(org.apache.hadoop.hbase.regionserver.HStore store,
                                   int count,
                                   int timeout)
                            throws InterruptedException

Throws:

InterruptedException