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 n
void	testCommitFile()
void	testGetFromFiles() Getting MOB data from files n
void	testGetFromMemStore() Getting data from memstore n
void	testGetFromMemStoreAndFiles() Getting data from memstore and files n
void	testGetReferencesFromFiles() Getting the reference data from files n
void	testMobCellSizeThreshold() Getting data from memstore and files n
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 n

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 n

Throws:

IOException

testGetFromFiles

public void testGetFromFiles()
                      throws IOException

Getting MOB data from files n

Throws:

IOException

testGetReferencesFromFiles

public void testGetReferencesFromFiles()
                                throws IOException

Getting the reference data from files n

Throws:

IOException

testGetFromMemStoreAndFiles

public void testGetFromMemStoreAndFiles()
                                 throws IOException

Getting data from memstore and files n

Throws:

IOException

testMobCellSizeThreshold

public void testMobCellSizeThreshold()
                              throws IOException

Getting data from memstore and files n

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

Throws:

IOException

flushStore

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

Flush the memstore

Throws:

IOException

testMOBStoreEncryption

public void testMOBStoreEncryption()
                            throws Exception

Throws:

Exception

checkMobHFileEncrytption

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