Package org.apache.hadoop.hbase.client

Class TestBlockEvictionFromClient

java.lang.Object

org.apache.hadoop.hbase.client.TestBlockEvictionFromClient

@Tag("org.apache.hadoop.hbase.testclassification.LargeTests") @Tag("org.apache.hadoop.hbase.testclassification.ClientTests")
public class TestBlockEvictionFromClient
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	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	Description
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 final org.slf4j.Logger	LOG
private String	methodName
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 final HBaseTestingUtil	TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
TestBlockEvictionFromClient()

Method Summary

Modifier and Type	Method	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(org.junit.jupiter.api.TestInfo testInfo)
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 Details

LOG

private static final org.slf4j.Logger LOG

TEST_UTIL

protected static final HBaseTestingUtil 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

methodName

private String methodName

Constructor Details

TestBlockEvictionFromClient

public TestBlockEvictionFromClient()

Method Details

setUp

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

Throws:

Exception

setUpBeforeClass

@BeforeAll
public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

@AfterAll
public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

tearDown

@AfterEach
public void tearDown()
              throws Exception

Throws:

Exception

testBlockEvictionWithParallelScans

@Test
public void testBlockEvictionWithParallelScans()
                                        throws Exception

Throws:

Exception

testParallelGetsAndScans

@Test
public void testParallelGetsAndScans()
                              throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testGetWithCellsInDifferentFiles

@Test
public void testGetWithCellsInDifferentFiles()
                                      throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testGetsWithMultiColumnsAndExplicitTracker

@Test
public void testGetsWithMultiColumnsAndExplicitTracker()
                                                throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testGetWithMultipleColumnFamilies

@Test
public void testGetWithMultipleColumnFamilies()
                                       throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testBlockRefCountAfterSplits

@Test
public void testBlockRefCountAfterSplits()
                                  throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testMultiGets

@Test
public void testMultiGets()
                   throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testScanWithMultipleColumnFamilies

@Test
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

@Test
public void testParallelGetsAndScanWithWrappedRegionScanner()
                                                     throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testScanWithCompaction

@Test
public void testScanWithCompaction()
                            throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testReverseScanWithCompaction

@Test
public void testReverseScanWithCompaction()
                                   throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testScanWithCompactionInternals

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

Throws:

IOException

InterruptedException

testBlockEvictionAfterHBASE13082WithCompactionAndFlush

@Test
public void testBlockEvictionAfterHBASE13082WithCompactionAndFlush()
                                                            throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testScanWithException

@Test
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