org.apache.hadoop.hbase.regionserver

Class TestSCVFWithMiniCluster

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestSCVFWithMiniCluster

public class TestSCVFWithMiniCluster
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private int	expected
private static byte[]	FAMILY_A
private static byte[]	FAMILY_B
private static org.apache.hadoop.hbase.TableName	HBASE_TABLE_NAME
private static org.apache.hadoop.hbase.client.Table	htable
private static byte[]	QUALIFIER_BAR
private static byte[]	QUALIFIER_FOO
private static org.apache.hadoop.hbase.filter.Filter	scanFilter

Constructor Summary

Constructors

Constructor and Description
TestSCVFWithMiniCluster()

Method Summary

Modifier and Type	Method and Description
private static void	create(org.apache.hadoop.hbase.client.Admin admin, org.apache.hadoop.hbase.TableName tableName, byte[]... families)
private static void	destroy(org.apache.hadoop.hbase.client.Admin admin, org.apache.hadoop.hbase.TableName tableName)
void	scanWithAllQualifiersOfBothFamilies() Test the filter by adding all columns of family A and B in the scan.
void	scanWithAllQualifiersOfFamiliyA() Test the filter by adding all columns of family A in the scan.
void	scanWithSpecificQualifiers1() Test the filter by adding 2 columns of family A and 1 column of family B in the scan.
void	scanWithSpecificQualifiers2() Test the filter by adding 1 column of family A (the one used in the filter) and 1 column of family B in the scan.
void	scanWithSpecificQualifiers3() Test the filter by adding 2 columns of family A in the scan.
static void	setUp()
static void	tearDown()
private void	verify(org.apache.hadoop.hbase.client.Scan scan)

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

HBASE_TABLE_NAME

private static final org.apache.hadoop.hbase.TableName HBASE_TABLE_NAME

FAMILY_A

private static final byte[] FAMILY_A

FAMILY_B

private static final byte[] FAMILY_B

QUALIFIER_FOO

private static final byte[] QUALIFIER_FOO

QUALIFIER_BAR

private static final byte[] QUALIFIER_BAR

htable

private static org.apache.hadoop.hbase.client.Table htable

scanFilter

private static org.apache.hadoop.hbase.filter.Filter scanFilter

expected

private int expected

Constructor Detail

TestSCVFWithMiniCluster

public TestSCVFWithMiniCluster()

Method Detail

setUp

public static void setUp()
                  throws Exception

Throws:

Exception

tearDown

public static void tearDown()
                     throws Exception

Throws:

Exception

verify

private void verify(org.apache.hadoop.hbase.client.Scan scan)
             throws IOException

Throws:

IOException

scanWithAllQualifiersOfFamiliyA

public void scanWithAllQualifiersOfFamiliyA()
                                     throws IOException

Test the filter by adding all columns of family A in the scan. (OK)

Throws:

IOException

scanWithAllQualifiersOfBothFamilies

public void scanWithAllQualifiersOfBothFamilies()
                                         throws IOException

Test the filter by adding all columns of family A and B in the scan. (KO: row '3' without 'a:foo' qualifier is returned)

Throws:

IOException

scanWithSpecificQualifiers1

public void scanWithSpecificQualifiers1()
                                 throws IOException

Test the filter by adding 2 columns of family A and 1 column of family B in the scan. (KO: row '3' without 'a:foo' qualifier is returned)

Throws:

IOException

scanWithSpecificQualifiers2

public void scanWithSpecificQualifiers2()
                                 throws IOException

Test the filter by adding 1 column of family A (the one used in the filter) and 1 column of family B in the scan. (OK)

Throws:

IOException

scanWithSpecificQualifiers3

public void scanWithSpecificQualifiers3()
                                 throws IOException

Test the filter by adding 2 columns of family A in the scan. (OK)

Throws:

IOException

create

private static void create(org.apache.hadoop.hbase.client.Admin admin,
                           org.apache.hadoop.hbase.TableName tableName,
                           byte[]... families)
                    throws IOException

Throws:

IOException

destroy

private static void destroy(org.apache.hadoop.hbase.client.Admin admin,
                            org.apache.hadoop.hbase.TableName tableName)
                     throws IOException

Throws:

IOException