Package org.apache.hadoop.hbase.mob

Class TestMobStoreScanner

java.lang.Object

org.apache.hadoop.hbase.mob.TestMobStoreScanner

public class TestMobStoreScanner
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private static org.apache.hadoop.hbase.client.Admin	admin
static final HBaseClassTestRule	CLASS_RULE
private org.apache.hadoop.conf.Configuration	conf
private static long	defaultThreshold
private static final byte[]	family
private static org.apache.hadoop.hbase.client.ColumnFamilyDescriptor	familyDescriptor
private org.apache.hadoop.fs.FileSystem	fs
org.junit.rules.TestName	name
private static final byte[]	qf1
private static final byte[]	qf2
protected final byte[]	qf3
private static final byte[]	row1
private static final byte[]	row2
private static org.apache.hadoop.hbase.client.Table	table
private static org.apache.hadoop.hbase.client.TableDescriptor	tableDescriptor
private static final HBaseTestingUtil	TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
TestMobStoreScanner()

Method Summary

Modifier and Type	Method	Description
private static void	assertIsMobReference(org.apache.hadoop.hbase.Cell cell, byte[] row, byte[] family, byte[] value, org.apache.hadoop.hbase.TableName tn)	Assert the value is store in mob.
private static void	assertNotMobReference(org.apache.hadoop.hbase.Cell cell, byte[] row, byte[] family, byte[] value)	Assert the value is not store in mob.
private void	createRecordAndCorruptMobFile(org.apache.hadoop.hbase.TableName tn, byte[] row, byte[] family, byte[] qf, byte[] value)
private static byte[]	generateMobValue(int size)	Generate the mob value.
private org.apache.hadoop.fs.Path	getFlushedMobFile(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.hbase.TableName table, String family)
void	setScan(org.apache.hadoop.hbase.client.Scan scan, boolean reversed, boolean mobScanRaw)	Set the scan attribute
void	setUp(long threshold, org.apache.hadoop.hbase.TableName tn)
static void	setUpBeforeClass()
static void	tearDownAfterClass()
private void	testGet(org.apache.hadoop.hbase.TableName tableName, boolean reversed, boolean doFlush)
private void	testGetFromArchive(boolean reversed)
private void	testGetFromFiles(boolean reversed)
private void	testGetFromMemStore(boolean reversed)
void	testGetMassive()
private void	testGetReferences(boolean reversed)
void	testMobStoreScanner()
private void	testMobThreshold(boolean reversed)
void	testReadFromCorruptMobFiles()
void	testReadFromCorruptMobFilesWithReadEmptyValueOnMobCellMiss()
void	testReadPt()
void	testReversedMobStoreScanner()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

TEST_UTIL

private static final HBaseTestingUtil TEST_UTIL

row1

private static final byte[] row1

row2

private static final byte[] row2

family

private static final byte[] family

qf1

private static final byte[] qf1

qf2

private static final byte[] qf2

qf3

protected final byte[] qf3

table

private static org.apache.hadoop.hbase.client.Table table

admin

private static org.apache.hadoop.hbase.client.Admin admin

familyDescriptor

private static org.apache.hadoop.hbase.client.ColumnFamilyDescriptor familyDescriptor

tableDescriptor

private static org.apache.hadoop.hbase.client.TableDescriptor tableDescriptor

defaultThreshold

private static long defaultThreshold

fs

private org.apache.hadoop.fs.FileSystem fs

conf

private org.apache.hadoop.conf.Configuration conf

name

public org.junit.rules.TestName name

Constructor Details

TestMobStoreScanner

public TestMobStoreScanner()

Method Details

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

setUp

public void setUp(long threshold,
 org.apache.hadoop.hbase.TableName tn)
           throws Exception

Throws:

Exception

generateMobValue

private static byte[] generateMobValue(int size)

Generate the mob value.

Parameters:

size - the size of the value

Returns:

the mob value generated

setScan

public void setScan(org.apache.hadoop.hbase.client.Scan scan,
 boolean reversed,
 boolean mobScanRaw)

Set the scan attribute

Parameters:

reversed - if true, scan will be backward order

mobScanRaw - if true, scan will get the mob reference

testMobStoreScanner

public void testMobStoreScanner()
                         throws Exception

Throws:

Exception

testReversedMobStoreScanner

public void testReversedMobStoreScanner()
                                 throws Exception

Throws:

Exception

testGetMassive

public void testGetMassive()
                    throws Exception

Throws:

Exception

testReadPt

public void testReadPt()
                throws Exception

Throws:

Exception

testReadFromCorruptMobFilesWithReadEmptyValueOnMobCellMiss

public void testReadFromCorruptMobFilesWithReadEmptyValueOnMobCellMiss()
                                                                throws Exception

Throws:

Exception

testReadFromCorruptMobFiles

public void testReadFromCorruptMobFiles()
                                 throws Exception

Throws:

Exception

createRecordAndCorruptMobFile

private void createRecordAndCorruptMobFile(org.apache.hadoop.hbase.TableName tn,
 byte[] row,
 byte[] family,
 byte[] qf,
 byte[] value)
                                    throws IOException

Throws:

IOException

getFlushedMobFile

private org.apache.hadoop.fs.Path getFlushedMobFile(org.apache.hadoop.conf.Configuration conf,
 org.apache.hadoop.fs.FileSystem fs,
 org.apache.hadoop.hbase.TableName table,
 String family)
                                             throws IOException

Throws:

IOException

testGetFromFiles

private void testGetFromFiles(boolean reversed)
                       throws Exception

Throws:

Exception

testGetFromMemStore

private void testGetFromMemStore(boolean reversed)
                          throws Exception

Throws:

Exception

testGet

private void testGet(org.apache.hadoop.hbase.TableName tableName,
 boolean reversed,
 boolean doFlush)
              throws Exception

Throws:

Exception

testGetReferences

private void testGetReferences(boolean reversed)
                        throws Exception

Throws:

Exception

testMobThreshold

private void testMobThreshold(boolean reversed)
                       throws Exception

Throws:

Exception

testGetFromArchive

private void testGetFromArchive(boolean reversed)
                         throws Exception

Throws:

Exception

assertNotMobReference

private static void assertNotMobReference(org.apache.hadoop.hbase.Cell cell,
 byte[] row,
 byte[] family,
 byte[] value)
                                   throws IOException

Assert the value is not store in mob.

Throws:

IOException

assertIsMobReference

private static void assertIsMobReference(org.apache.hadoop.hbase.Cell cell,
 byte[] row,
 byte[] family,
 byte[] value,
 org.apache.hadoop.hbase.TableName tn)
                                  throws IOException

Assert the value is store in mob.

Throws:

IOException