Package org.apache.hadoop.hbase.mob

Class TestMobStoreScanner

java.lang.Object

org.apache.hadoop.hbase.mob.TestMobStoreScanner

@Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
public class TestMobStoreScanner
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private static org.apache.hadoop.hbase.client.Admin	admin
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
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
private String	testMethodName

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()
void	setUpTest(org.junit.jupiter.api.TestInfo testInfo)
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

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

testMethodName

private String testMethodName

Constructor Details

TestMobStoreScanner

public TestMobStoreScanner()

Method Details

setUpBeforeClass

@BeforeAll
public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

@AfterAll
public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

setUpTest

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

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

@Test
public void testMobStoreScanner()
                         throws Exception

Throws:

Exception

testReversedMobStoreScanner

@Test
public void testReversedMobStoreScanner()
                                 throws Exception

Throws:

Exception

testGetMassive

@Test
public void testGetMassive()
                    throws Exception

Throws:

Exception

testReadPt

@Test
public void testReadPt()
                throws Exception

Throws:

Exception

testReadFromCorruptMobFilesWithReadEmptyValueOnMobCellMiss

@Test
public void testReadFromCorruptMobFilesWithReadEmptyValueOnMobCellMiss()
                                                                throws Exception

Throws:

Exception

testReadFromCorruptMobFiles

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