org.apache.hadoop.hbase.filter

Class TestFilter

java.lang.Object

org.apache.hadoop.hbase.filter.TestFilter

public class TestFilter
extends Object

Test filters at the HRegion doorstep.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	TestFilter.OldTestFilter The following filter simulates a pre-0.96 filter where filterRow() is defined while hasFilterRow() returns false
static class	TestFilter.SlowScanFilter Filter which makes sleeps for a second between each row of a scan.

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private long	colsPerRow
private static byte[][]	FAMILIES
private static byte[][]	FAMILIES_1
private static org.slf4j.Logger	LOG
org.junit.rules.TestName	name
(package private) byte[][]	NEW_FAMILIES
private long	numRows
private static byte[][]	QUALIFIERS_FIVE
private static byte[][]	QUALIFIERS_FOUR
private static byte[][]	QUALIFIERS_ONE
private static byte[][]	QUALIFIERS_THREE
private static byte[][]	QUALIFIERS_TWO
private org.apache.hadoop.hbase.regionserver.HRegion	region
private static byte[][]	ROWS_FOUR
private static byte[][]	ROWS_ONE
private static byte[][]	ROWS_THREE
private static byte[][]	ROWS_TWO
private static HBaseTestingUtility	TEST_UTIL
private static byte[][]	VALUES

Constructor Summary

Constructors

Constructor and Description
TestFilter()

Method Summary

Modifier and Type	Method and Description
void	setUp()
void	tearDown()
void	test94FilterRowCompatibility() The following test is to ensure old(such as hbase0.94) filterRow() can be correctly fired in 0.96+ code base.
void	testColumnPaginationFilter()
void	testColumnPaginationFilterColumnOffset()
void	testColumnValueFilter()
void	testFamilyFilter()
void	testFilterList()
void	testFilterListWithPrefixFilter()
void	testFilterListWithSingleColumnValueFilter()
void	testFirstKeyOnlyFilter()
void	testInclusiveStopFilter()
void	testInclusiveStopFilterWithReverseScan()
void	testKeyOnlyFilter()
void	testLatestVersionFilterWithExplicitColumn()
void	testNestedFilterListWithSCVF()
void	testNoFilter()
void	testPageFilter()
void	testPageFilterWithReverseScan()
void	testPrefixFilter()
void	testPrefixFilterWithReverseScan()
void	testQualifierFilter()
void	testRegionScannerReseek()
void	testRowFilter()
void	testSingleColumnValueFilter()
void	testSkipFilter()
void	testValueFilter()
void	testWhileMatchFilterWithFilterCell() Tests the the WhileMatchFilter works in combination with a Filter that uses the Filter.filterCell(Cell) method.
void	testWhileMatchFilterWithFilterRow() Tests the the WhileMatchFilter works in combination with a Filter that uses the Filter.filterRow() method.
void	testWhileMatchFilterWithFilterRowKey() Tests the the WhileMatchFilter works in combination with a Filter that uses the Filter.filterRowKey(Cell) method.
void	testWhileMatchFilterWithFilterRowKeyWithReverseScan()
void	testWhileMatchFilterWithFilterRowWithReverseScan()
private void	verifyScan(org.apache.hadoop.hbase.client.Scan s, long expectedRows, long expectedKeys)
private void	verifyScanFull(org.apache.hadoop.hbase.client.Scan s, org.apache.hadoop.hbase.KeyValue[] kvs)
private void	verifyScanFullNoValues(org.apache.hadoop.hbase.client.Scan s, org.apache.hadoop.hbase.KeyValue[] kvs, boolean useLen)
private void	verifyScanNoEarlyOut(org.apache.hadoop.hbase.client.Scan s, long expectedRows, long expectedKeys)

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

private static final org.slf4j.Logger LOG

region

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

TEST_UTIL

private static final HBaseTestingUtility TEST_UTIL

name

public org.junit.rules.TestName name

ROWS_ONE

private static final byte[][] ROWS_ONE

ROWS_TWO

private static final byte[][] ROWS_TWO

ROWS_THREE

private static final byte[][] ROWS_THREE

ROWS_FOUR

private static final byte[][] ROWS_FOUR

FAMILIES

private static final byte[][] FAMILIES

FAMILIES_1

private static final byte[][] FAMILIES_1

QUALIFIERS_ONE

private static final byte[][] QUALIFIERS_ONE

QUALIFIERS_TWO

private static final byte[][] QUALIFIERS_TWO

QUALIFIERS_THREE

private static final byte[][] QUALIFIERS_THREE

QUALIFIERS_FOUR

private static final byte[][] QUALIFIERS_FOUR

QUALIFIERS_FIVE

private static final byte[][] QUALIFIERS_FIVE

VALUES

private static final byte[][] VALUES

NEW_FAMILIES

byte[][] NEW_FAMILIES

numRows

private long numRows

colsPerRow

private long colsPerRow

Constructor Detail

TestFilter

public TestFilter()

Method Detail

setUp

public void setUp()
           throws Exception

Throws:

Exception

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

testRegionScannerReseek

public void testRegionScannerReseek()
                             throws Exception

Throws:

Exception

testNoFilter

public void testNoFilter()
                  throws Exception

Throws:

Exception

testPrefixFilter

public void testPrefixFilter()
                      throws Exception

Throws:

Exception

testPrefixFilterWithReverseScan

public void testPrefixFilterWithReverseScan()
                                     throws Exception

Throws:

Exception

testPageFilter

public void testPageFilter()
                    throws Exception

Throws:

Exception

testPageFilterWithReverseScan

public void testPageFilterWithReverseScan()
                                   throws Exception

Throws:

Exception

testWhileMatchFilterWithFilterRowWithReverseScan

public void testWhileMatchFilterWithFilterRowWithReverseScan()
                                                      throws Exception

Throws:

Exception

testWhileMatchFilterWithFilterRowKeyWithReverseScan

public void testWhileMatchFilterWithFilterRowKeyWithReverseScan()
                                                         throws Exception

Throws:

Exception

testWhileMatchFilterWithFilterRow

public void testWhileMatchFilterWithFilterRow()
                                       throws Exception

Tests the the WhileMatchFilter works in combination with a Filter that uses the Filter.filterRow() method. See HBASE-2258.

Throws:

Exception

test94FilterRowCompatibility

public void test94FilterRowCompatibility()
                                  throws Exception

The following test is to ensure old(such as hbase0.94) filterRow() can be correctly fired in 0.96+ code base. See HBASE-10366

Throws:

Exception

testWhileMatchFilterWithFilterRowKey

public void testWhileMatchFilterWithFilterRowKey()
                                          throws Exception

Tests the the WhileMatchFilter works in combination with a Filter that uses the Filter.filterRowKey(Cell) method. See HBASE-2258.

Throws:

Exception

testWhileMatchFilterWithFilterCell

public void testWhileMatchFilterWithFilterCell()
                                        throws Exception

Tests the the WhileMatchFilter works in combination with a Filter that uses the Filter.filterCell(Cell) method. See HBASE-2258.

Throws:

Exception

testInclusiveStopFilter

public void testInclusiveStopFilter()
                             throws IOException

Throws:

IOException

testInclusiveStopFilterWithReverseScan

public void testInclusiveStopFilterWithReverseScan()
                                            throws IOException

Throws:

IOException

testQualifierFilter

public void testQualifierFilter()
                         throws IOException

Throws:

IOException

testFamilyFilter

public void testFamilyFilter()
                      throws IOException

Throws:

IOException

testRowFilter

public void testRowFilter()
                   throws IOException

Throws:

IOException

testValueFilter

public void testValueFilter()
                     throws IOException

Throws:

IOException

testSkipFilter

public void testSkipFilter()
                    throws IOException

Throws:

IOException

testFilterList

public void testFilterList()
                    throws IOException

Throws:

IOException

testFirstKeyOnlyFilter

public void testFirstKeyOnlyFilter()
                            throws IOException

Throws:

IOException

testFilterListWithSingleColumnValueFilter

public void testFilterListWithSingleColumnValueFilter()
                                               throws IOException

Throws:

IOException

testFilterListWithPrefixFilter

public void testFilterListWithPrefixFilter()
                                    throws IOException

Throws:

IOException

testSingleColumnValueFilter

public void testSingleColumnValueFilter()
                                 throws IOException

Throws:

IOException

testColumnValueFilter

public void testColumnValueFilter()
                           throws Exception

Throws:

Exception

verifyScan

private void verifyScan(org.apache.hadoop.hbase.client.Scan s,
                        long expectedRows,
                        long expectedKeys)
                 throws IOException

Throws:

IOException

verifyScanNoEarlyOut

private void verifyScanNoEarlyOut(org.apache.hadoop.hbase.client.Scan s,
                                  long expectedRows,
                                  long expectedKeys)
                           throws IOException

Throws:

IOException

verifyScanFull

private void verifyScanFull(org.apache.hadoop.hbase.client.Scan s,
                            org.apache.hadoop.hbase.KeyValue[] kvs)
                     throws IOException

Throws:

IOException

verifyScanFullNoValues

private void verifyScanFullNoValues(org.apache.hadoop.hbase.client.Scan s,
                                    org.apache.hadoop.hbase.KeyValue[] kvs,
                                    boolean useLen)
                             throws IOException

Throws:

IOException

testColumnPaginationFilterColumnOffset

public void testColumnPaginationFilterColumnOffset()
                                            throws Exception

Throws:

Exception

testLatestVersionFilterWithExplicitColumn

public void testLatestVersionFilterWithExplicitColumn()
                                               throws Exception

Throws:

Exception

testColumnPaginationFilter

public void testColumnPaginationFilter()
                                throws Exception

Throws:

Exception

testKeyOnlyFilter

public void testKeyOnlyFilter()
                       throws Exception

Throws:

Exception

testNestedFilterListWithSCVF

public void testNestedFilterListWithSCVF()
                                  throws IOException

Throws:

IOException