Package org.apache.hadoop.hbase.regionserver

Class TestBlocksRead

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestBlocksRead

@Tag("org.apache.hadoop.hbase.testclassification.RegionServerTests") @Tag("org.apache.hadoop.hbase.testclassification.SmallTests")
public class TestBlocksRead
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static final org.apache.hadoop.hbase.regionserver.BloomType[]	BLOOM_TYPE
private org.apache.hadoop.conf.Configuration	conf
private final String	DIR
private static final org.slf4j.Logger	LOG
(package private) org.apache.hadoop.hbase.regionserver.HRegion	region
private static HBaseTestingUtil	TEST_UTIL
private String	testName

Constructor Summary

Constructors

Constructor	Description
TestBlocksRead()

Method Summary

Modifier and Type	Method	Description
private void	deleteFamily(String family, String row, long version)
private static byte[]	genValue(String row, String col, long version)
private static long	getBlkAccessCount(byte[] cf)
private org.apache.hadoop.hbase.Cell[]	getData(String family, String row, String column, int expBlocks)
private org.apache.hadoop.hbase.Cell[]	getData(String family, String row, String column, int expBlocksRowCol, int expBlocksRow, int expBlocksNone)
private org.apache.hadoop.hbase.Cell[]	getData(String family, String row, List<String> columns, int expBlocks)
private org.apache.hadoop.hbase.Cell[]	getData(String family, String row, List<String> columns, int expBlocksRowCol, int expBlocksRow, int expBlocksNone)
private org.apache.hadoop.hbase.regionserver.HRegion	initHRegion(byte[] tableName, String callingMethod, org.apache.hadoop.conf.Configuration conf, String family)	Callers must afterward call HBaseTestingUtil.closeRegionAndWAL(HRegion)
private org.apache.hadoop.hbase.regionserver.HRegion	initHRegion(byte[] tableName, String callingMethod, org.apache.hadoop.conf.Configuration conf, String family, org.apache.hadoop.hbase.io.hfile.BlockCache blockCache)	Callers must afterward call HBaseTestingUtil.closeRegionAndWAL(HRegion)
private void	putData(byte[] cf, String row, String col, long versionStart, long versionEnd)
private void	putData(String family, String row, String col, long version)
void	setTestName(org.junit.jupiter.api.TestInfo testInfo)
static void	setUp()
static void	tearDown()
void	testBlocksRead()	Test # of blocks read for some simple seek cases.
void	testBlocksStoredWhenCachingDisabled()	Test # of blocks read to ensure disabling cache-fill on Scan works.
void	testLazySeekBlocksRead()	Test # of blocks read (targeted at some of the cases Lazy Seek optimizes).
void	testLazySeekBlocksReadWithDelete()
private static void	verifyData(org.apache.hadoop.hbase.Cell kv, String expectedRow, String expectedCol, long expectedVersion)

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

testName

private String testName

BLOOM_TYPE

static final org.apache.hadoop.hbase.regionserver.BloomType[] BLOOM_TYPE

region

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

TEST_UTIL

private static HBaseTestingUtil TEST_UTIL

DIR

private final String DIR

conf

private org.apache.hadoop.conf.Configuration conf

Constructor Details

TestBlocksRead

public TestBlocksRead()

Method Details

setTestName

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

setUp

@BeforeAll
public static void setUp()
                  throws Exception

Throws:

Exception

tearDown

@AfterAll
public static void tearDown()
                     throws Exception

Throws:

Exception

initHRegion

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

Callers must afterward call HBaseTestingUtil.closeRegionAndWAL(HRegion)

Returns:

created and initialized region.

Throws:

IOException

initHRegion

private org.apache.hadoop.hbase.regionserver.HRegion initHRegion(byte[] tableName,
 String callingMethod,
 org.apache.hadoop.conf.Configuration conf,
 String family,
 org.apache.hadoop.hbase.io.hfile.BlockCache blockCache)
                                                          throws IOException

Callers must afterward call HBaseTestingUtil.closeRegionAndWAL(HRegion)

Throws:

IOException

putData

private void putData(String family,
 String row,
 String col,
 long version)
              throws IOException

Throws:

IOException

genValue

private static byte[] genValue(String row,
 String col,
 long version)

putData

private void putData(byte[] cf,
 String row,
 String col,
 long versionStart,
 long versionEnd)
              throws IOException

Throws:

IOException

getData

private org.apache.hadoop.hbase.Cell[] getData(String family,
 String row,
 List<String> columns,
 int expBlocks)
                                        throws IOException

Throws:

IOException

getData

private org.apache.hadoop.hbase.Cell[] getData(String family,
 String row,
 List<String> columns,
 int expBlocksRowCol,
 int expBlocksRow,
 int expBlocksNone)
                                        throws IOException

Throws:

IOException

getData

private org.apache.hadoop.hbase.Cell[] getData(String family,
 String row,
 String column,
 int expBlocks)
                                        throws IOException

Throws:

IOException

getData

private org.apache.hadoop.hbase.Cell[] getData(String family,
 String row,
 String column,
 int expBlocksRowCol,
 int expBlocksRow,
 int expBlocksNone)
                                        throws IOException

Throws:

IOException

deleteFamily

private void deleteFamily(String family,
 String row,
 long version)
                   throws IOException

Throws:

IOException

verifyData

private static void verifyData(org.apache.hadoop.hbase.Cell kv,
 String expectedRow,
 String expectedCol,
 long expectedVersion)

getBlkAccessCount

private static long getBlkAccessCount(byte[] cf)

testBlocksRead

@Test
public void testBlocksRead()
                    throws Exception

Test # of blocks read for some simple seek cases.

Throws:

Exception

testLazySeekBlocksRead

@Test
public void testLazySeekBlocksRead()
                            throws Exception

Test # of blocks read (targeted at some of the cases Lazy Seek optimizes).

Throws:

Exception

testBlocksStoredWhenCachingDisabled

@Test
public void testBlocksStoredWhenCachingDisabled()
                                         throws Exception

Test # of blocks read to ensure disabling cache-fill on Scan works.

Throws:

Exception

testLazySeekBlocksReadWithDelete

@Test
public void testLazySeekBlocksReadWithDelete()
                                      throws Exception

Throws:

Exception