org.apache.hadoop.hbase.regionserver

Class TestHMobStore

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestHMobStore

public class TestHMobStore
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private Date	currentDate
private String	DIR
private List<org.apache.hadoop.hbase.Cell>	expected
private byte[]	family
private org.apache.hadoop.fs.FileSystem	fs
private org.apache.hadoop.hbase.client.Get	get
private long	id
static org.slf4j.Logger	LOG
private org.apache.hadoop.fs.Path	mobFilePath
org.junit.rules.TestName	name
private byte[]	qf1
private byte[]	qf2
private byte[]	qf3
private byte[]	qf4
private byte[]	qf5
private byte[]	qf6
private NavigableSet<byte[]>	qualifiers
private org.apache.hadoop.hbase.regionserver.HRegion	region
private byte[]	row
private byte[]	row2
private org.apache.hadoop.hbase.Cell	seekKey1
private org.apache.hadoop.hbase.Cell	seekKey2
private org.apache.hadoop.hbase.Cell	seekKey3
private org.apache.hadoop.hbase.regionserver.HMobStore	store
private byte[]	table
private static HBaseTestingUtility	TEST_UTIL
private byte[]	value
private byte[]	value2

Constructor Summary

Constructors

Constructor and Description
TestHMobStore()

Method Summary

Modifier and Type	Method and Description
private void	checkMobHFileEncrytption(Collection<org.apache.hadoop.hbase.regionserver.HStoreFile> storefiles)
private void	flush(int storeFilesSize) Flush the memstore
private static void	flushStore(org.apache.hadoop.hbase.regionserver.HMobStore store, long id) Flush the memstore
private void	init(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.ColumnFamilyDescriptor cfd)
private void	init(String methodName, org.apache.hadoop.conf.Configuration conf, boolean testStore)
private void	init(String methodName, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.client.ColumnFamilyDescriptor cfd, boolean testStore)
void	setUp() Setup
void	testCommitFile()
void	testGetFromFiles() Getting MOB data from files
void	testGetFromMemStore() Getting data from memstore
void	testGetFromMemStoreAndFiles() Getting data from memstore and files
void	testGetReferencesFromFiles() Getting the reference data from files
void	testMobCellSizeThreshold() Getting data from memstore and files
void	testMOBStoreEncryption()
void	testResolve()

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

public static final org.slf4j.Logger LOG

name

public org.junit.rules.TestName name

store

private org.apache.hadoop.hbase.regionserver.HMobStore store

region

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

fs

private org.apache.hadoop.fs.FileSystem fs

table

private byte[] table

family

private byte[] family

row

private byte[] row

row2

private byte[] row2

qf1

private byte[] qf1

qf2

private byte[] qf2

qf3

private byte[] qf3

qf4

private byte[] qf4

qf5

private byte[] qf5

qf6

private byte[] qf6

value

private byte[] value

value2

private byte[] value2

mobFilePath

private org.apache.hadoop.fs.Path mobFilePath

currentDate

private Date currentDate

seekKey1

private org.apache.hadoop.hbase.Cell seekKey1

seekKey2

private org.apache.hadoop.hbase.Cell seekKey2

seekKey3

private org.apache.hadoop.hbase.Cell seekKey3

qualifiers

private NavigableSet<byte[]> qualifiers

expected

private List<org.apache.hadoop.hbase.Cell> expected

id

private long id

get

private org.apache.hadoop.hbase.client.Get get

TEST_UTIL

private static final HBaseTestingUtility TEST_UTIL

DIR

private final String DIR

Constructor Detail

TestHMobStore

public TestHMobStore()

Method Detail

setUp

public void setUp()
           throws Exception

Setup

Throws:

Exception

init

private void init(String methodName,
                  org.apache.hadoop.conf.Configuration conf,
                  boolean testStore)
           throws IOException

Throws:

IOException

init

private void init(String methodName,
                  org.apache.hadoop.conf.Configuration conf,
                  org.apache.hadoop.hbase.client.ColumnFamilyDescriptor cfd,
                  boolean testStore)
           throws IOException

Throws:

IOException

init

private void init(org.apache.hadoop.conf.Configuration conf,
                  org.apache.hadoop.hbase.client.ColumnFamilyDescriptor cfd)
           throws IOException

Throws:

IOException

testGetFromMemStore

public void testGetFromMemStore()
                         throws IOException

Getting data from memstore

Throws:

IOException

testGetFromFiles

public void testGetFromFiles()
                      throws IOException

Getting MOB data from files

Throws:

IOException

testGetReferencesFromFiles

public void testGetReferencesFromFiles()
                                throws IOException

Getting the reference data from files

Throws:

IOException

testGetFromMemStoreAndFiles

public void testGetFromMemStoreAndFiles()
                                 throws IOException

Getting data from memstore and files

Throws:

IOException

testMobCellSizeThreshold

public void testMobCellSizeThreshold()
                              throws IOException

Getting data from memstore and files

Throws:

IOException

testCommitFile

public void testCommitFile()
                    throws Exception

Throws:

Exception

testResolve

public void testResolve()
                 throws Exception

Throws:

Exception

flush

private void flush(int storeFilesSize)
            throws IOException

Flush the memstore

Parameters:

storeFilesSize -

Throws:

IOException

flushStore

private static void flushStore(org.apache.hadoop.hbase.regionserver.HMobStore store,
                               long id)
                        throws IOException

Flush the memstore

Parameters:

store -

id -

Throws:

IOException

testMOBStoreEncryption

public void testMOBStoreEncryption()
                            throws Exception

Throws:

Exception

checkMobHFileEncrytption

private void checkMobHFileEncrytption(Collection<org.apache.hadoop.hbase.regionserver.HStoreFile> storefiles)