Package org.apache.hadoop.hbase.regionserver

Class TestReversibleScanners

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestReversibleScanners

public class TestReversibleScanners
extends Object

Test cases against ReversibleKeyValueScanner

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static byte[]	FAMILYNAME
private static final org.slf4j.Logger	LOG
private static int	MAXMVCC
org.junit.rules.TestName	name
private static byte[]	QUAL
private static byte[][]	QUALS
private static final int	QUALSIZE
private static byte[]	ROW
private static byte[][]	ROWS
private static final int	ROWSIZE
(package private) HBaseTestingUtility	TEST_UTIL
private static long	TS
private static byte[]	VALUE
private static byte[][]	VALUES
private static final int	VALUESIZE

Constructor Summary

Constructors

Constructor	Description
TestReversibleScanners()

Method Summary

Modifier and Type	Method	Description
private org.apache.hadoop.hbase.KeyValue	getNextReadableKeyValueWithBackwardScan(int startRowNum, int startQualNum, int readPoint)
private org.apache.hadoop.hbase.util.Pair<Integer,Integer>	getNextReadableNumWithBackwardScan(int startRowNum, int startQualNum, int readPoint)
private org.apache.hadoop.hbase.regionserver.ReversedKeyValueHeap	getReversibleKeyValueHeap(org.apache.hadoop.hbase.regionserver.MemStore memstore, org.apache.hadoop.hbase.regionserver.HStoreFile sf1, org.apache.hadoop.hbase.regionserver.HStoreFile sf2, byte[] startRow, int readPoint)
private org.apache.hadoop.hbase.regionserver.StoreScanner	getReversibleStoreScanner(org.apache.hadoop.hbase.regionserver.MemStore memstore, org.apache.hadoop.hbase.regionserver.HStoreFile sf1, org.apache.hadoop.hbase.regionserver.HStoreFile sf2, org.apache.hadoop.hbase.client.Scan scan, org.apache.hadoop.hbase.regionserver.ScanInfo scanInfo, int readPoint)
private List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>	getScanners(org.apache.hadoop.hbase.regionserver.MemStore memstore, org.apache.hadoop.hbase.regionserver.HStoreFile sf1, org.apache.hadoop.hbase.regionserver.HStoreFile sf2, byte[] startRow, boolean doSeek, int readPoint)
private void	internalTestSeekAndNextForReversibleKeyValueHeap(org.apache.hadoop.hbase.regionserver.ReversedKeyValueHeap kvHeap, int startRowNum)
private static void	loadDataToRegion(org.apache.hadoop.hbase.regionserver.HRegion region, byte[] additionalFamily)
private static org.apache.hadoop.hbase.KeyValue	makeKV(int rowNum, int cqNum)
private static org.apache.hadoop.hbase.KeyValue	makeKV(int rowNum, int cqNum, byte[] familyName)
private static long	makeMVCC(int rowNum, int cqNum)
private static byte[][]	makeN(byte[] base, int n)
private void	seekTestOfReversibleKeyValueScanner(org.apache.hadoop.hbase.regionserver.KeyValueScanner scanner)
private void	seekTestOfReversibleKeyValueScannerWithMVCC(List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners, int readPoint)
static void	setUp()
void	testReversibleKeyValueHeap()
void	testReversibleMemstoreScanner()
void	testReversibleRegionScanner()
void	testReversibleStoreFileScanner()
void	testReversibleStoreScanner()
private void	verifyCountAndOrder(org.apache.hadoop.hbase.regionserver.InternalScanner scanner, int expectedKVCount, int expectedRowCount, boolean forward)
private static void	writeMemstore(org.apache.hadoop.hbase.regionserver.MemStore memstore)
private static void	writeMemstoreAndStoreFiles(org.apache.hadoop.hbase.regionserver.MemStore memstore, org.apache.hadoop.hbase.regionserver.StoreFileWriter[] writers)
private static void	writeStoreFile(org.apache.hadoop.hbase.regionserver.StoreFileWriter writer)

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

LOG

private static final org.slf4j.Logger LOG

TEST_UTIL

HBaseTestingUtility TEST_UTIL

FAMILYNAME

private static byte[] FAMILYNAME

TS

private static long TS

MAXMVCC

private static int MAXMVCC

ROW

private static byte[] ROW

ROWSIZE

private static final int ROWSIZE

See Also:

• Constant Field Values

ROWS

private static byte[][] ROWS

QUAL

private static byte[] QUAL

QUALSIZE

private static final int QUALSIZE

See Also:

• Constant Field Values

QUALS

private static byte[][] QUALS

VALUE

private static byte[] VALUE

VALUESIZE

private static final int VALUESIZE

See Also:

• Constant Field Values

VALUES

private static byte[][] VALUES

name

public org.junit.rules.TestName name

Constructor Details

TestReversibleScanners

public TestReversibleScanners()

Method Details

setUp

public static void setUp()

testReversibleStoreFileScanner

public void testReversibleStoreFileScanner()
                                    throws IOException

Throws:

IOException

testReversibleMemstoreScanner

public void testReversibleMemstoreScanner()
                                   throws IOException

Throws:

IOException

testReversibleKeyValueHeap

public void testReversibleKeyValueHeap()
                                throws IOException

Throws:

IOException

testReversibleStoreScanner

public void testReversibleStoreScanner()
                                throws IOException

Throws:

IOException

testReversibleRegionScanner

public void testReversibleRegionScanner()
                                 throws IOException

Throws:

IOException

getReversibleStoreScanner

private org.apache.hadoop.hbase.regionserver.StoreScanner getReversibleStoreScanner(org.apache.hadoop.hbase.regionserver.MemStore memstore,
 org.apache.hadoop.hbase.regionserver.HStoreFile sf1,
 org.apache.hadoop.hbase.regionserver.HStoreFile sf2,
 org.apache.hadoop.hbase.client.Scan scan,
 org.apache.hadoop.hbase.regionserver.ScanInfo scanInfo,
 int readPoint)
                                                                             throws IOException

Throws:

IOException

verifyCountAndOrder

private void verifyCountAndOrder(org.apache.hadoop.hbase.regionserver.InternalScanner scanner,
 int expectedKVCount,
 int expectedRowCount,
 boolean forward)
                          throws IOException

Throws:

IOException

internalTestSeekAndNextForReversibleKeyValueHeap

private void internalTestSeekAndNextForReversibleKeyValueHeap(org.apache.hadoop.hbase.regionserver.ReversedKeyValueHeap kvHeap,
 int startRowNum)
                                                       throws IOException

Throws:

IOException

getReversibleKeyValueHeap

private org.apache.hadoop.hbase.regionserver.ReversedKeyValueHeap getReversibleKeyValueHeap(org.apache.hadoop.hbase.regionserver.MemStore memstore,
 org.apache.hadoop.hbase.regionserver.HStoreFile sf1,
 org.apache.hadoop.hbase.regionserver.HStoreFile sf2,
 byte[] startRow,
 int readPoint)
                                                                                     throws IOException

Throws:

IOException

getScanners

private List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> getScanners(org.apache.hadoop.hbase.regionserver.MemStore memstore,
 org.apache.hadoop.hbase.regionserver.HStoreFile sf1,
 org.apache.hadoop.hbase.regionserver.HStoreFile sf2,
 byte[] startRow,
 boolean doSeek,
 int readPoint)
                                                                        throws IOException

Throws:

IOException

seekTestOfReversibleKeyValueScanner

private void seekTestOfReversibleKeyValueScanner(org.apache.hadoop.hbase.regionserver.KeyValueScanner scanner)
                                          throws IOException

Throws:

IOException

seekTestOfReversibleKeyValueScannerWithMVCC

private void seekTestOfReversibleKeyValueScannerWithMVCC(List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners,
 int readPoint)
                                                  throws IOException

Throws:

IOException

getNextReadableKeyValueWithBackwardScan

private org.apache.hadoop.hbase.KeyValue getNextReadableKeyValueWithBackwardScan(int startRowNum,
 int startQualNum,
 int readPoint)

getNextReadableNumWithBackwardScan

private org.apache.hadoop.hbase.util.Pair<Integer,Integer> getNextReadableNumWithBackwardScan(int startRowNum,
 int startQualNum,
 int readPoint)

loadDataToRegion

private static void loadDataToRegion(org.apache.hadoop.hbase.regionserver.HRegion region,
 byte[] additionalFamily)
                              throws IOException

Throws:

IOException

writeMemstoreAndStoreFiles

private static void writeMemstoreAndStoreFiles(org.apache.hadoop.hbase.regionserver.MemStore memstore,
 org.apache.hadoop.hbase.regionserver.StoreFileWriter[] writers)
                                        throws IOException

Throws:

IOException

writeStoreFile

private static void writeStoreFile(org.apache.hadoop.hbase.regionserver.StoreFileWriter writer)
                            throws IOException

Throws:

IOException

writeMemstore

private static void writeMemstore(org.apache.hadoop.hbase.regionserver.MemStore memstore)
                           throws IOException

Throws:

IOException

makeKV

private static org.apache.hadoop.hbase.KeyValue makeKV(int rowNum,
 int cqNum)

makeKV

private static org.apache.hadoop.hbase.KeyValue makeKV(int rowNum,
 int cqNum,
 byte[] familyName)

makeMVCC

private static long makeMVCC(int rowNum,
 int cqNum)

makeN

private static byte[][] makeN(byte[] base,
 int n)