org.apache.hadoop.hbase.regionserver

Class TestBlocksRead

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestBlocksRead

public class TestBlocksRead
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
(package private) static org.apache.hadoop.hbase.regionserver.BloomType[]	BLOOM_TYPE
static HBaseClassTestRule	CLASS_RULE
private org.apache.hadoop.conf.Configuration	conf
private String	DIR
private static org.slf4j.Logger	LOG
(package private) org.apache.hadoop.hbase.regionserver.HRegion	region
private static HBaseTestingUtility	TEST_UTIL
org.junit.rules.TestName	testName

Constructor Summary

Constructors

Constructor and Description
TestBlocksRead()

Method Summary

Modifier and Type	Method and 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, 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.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.regionserver.HRegion	initHRegion(byte[] tableName, String callingMethod, org.apache.hadoop.conf.Configuration conf, String family) Callers must afterward call HBaseTestingUtility.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 HBaseTestingUtility.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)
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 Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

testName

public org.junit.rules.TestName 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 HBaseTestingUtility TEST_UTIL

DIR

private final String DIR

conf

private org.apache.hadoop.conf.Configuration conf

Constructor Detail

TestBlocksRead

public TestBlocksRead()

Method Detail

setUp

public static void setUp()
                  throws Exception

Throws:

Exception

tearDown

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

public void testBlocksRead()
                    throws Exception

Test # of blocks read for some simple seek cases.

Throws:

Exception

testLazySeekBlocksRead

public void testLazySeekBlocksRead()
                            throws Exception

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

Throws:

Exception

testBlocksStoredWhenCachingDisabled

public void testBlocksStoredWhenCachingDisabled()
                                         throws Exception

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

Throws:

Exception

testLazySeekBlocksReadWithDelete

public void testLazySeekBlocksReadWithDelete()
                                      throws Exception

Throws:

Exception