org.apache.hadoop.hbase.coprocessor

Class TestBatchCoprocessorEndpoint

java.lang.Object

org.apache.hadoop.hbase.coprocessor.TestBatchCoprocessorEndpoint

public class TestBatchCoprocessorEndpoint
extends Object

TestEndpoint: test cases to verify the batch execution of coprocessor Endpoint

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static org.slf4j.Logger	LOG
private static byte[]	ROW
private static byte[][]	ROWS
private static int	rowSeperator1
private static int	rowSeperator2
private static int	ROWSIZE
private static byte[]	TEST_FAMILY
private static byte[]	TEST_QUALIFIER
private static org.apache.hadoop.hbase.TableName	TEST_TABLE
private static HBaseTestingUtility	util

Constructor Summary

Constructors

Constructor and Description
TestBatchCoprocessorEndpoint()

Method Summary

Modifier and Type	Method and Description
private static byte[][]	makeN(byte[] base, int n)
static void	setupBeforeClass()
private Map<byte[],org.apache.hadoop.hbase.coprocessor.protobuf.generated.ColumnAggregationProtos.SumResponse>	sum(org.apache.hadoop.hbase.client.Table table, byte[] family, byte[] qualifier, byte[] start, byte[] end)
static void	tearDownAfterClass()
void	testAggregation()
void	testAggregationNullResponse()
void	testAggregationWithErrors()
void	testAggregationWithReturnValue()

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

TEST_TABLE

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

TEST_FAMILY

private static final byte[] TEST_FAMILY

TEST_QUALIFIER

private static final byte[] TEST_QUALIFIER

ROW

private static byte[] ROW

ROWSIZE

private static final int ROWSIZE

See Also:

Constant Field Values

rowSeperator1

private static final int rowSeperator1

See Also:

Constant Field Values

rowSeperator2

private static final int rowSeperator2

See Also:

Constant Field Values

ROWS

private static byte[][] ROWS

util

private static HBaseTestingUtility util

Constructor Detail

TestBatchCoprocessorEndpoint

public TestBatchCoprocessorEndpoint()

Method Detail

setupBeforeClass

public static void setupBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

testAggregationNullResponse

public void testAggregationNullResponse()
                                 throws Throwable

Throws:

Throwable

makeN

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

sum

private Map<byte[],org.apache.hadoop.hbase.coprocessor.protobuf.generated.ColumnAggregationProtos.SumResponse> sum(org.apache.hadoop.hbase.client.Table table,
                                                                                                                   byte[] family,
                                                                                                                   byte[] qualifier,
                                                                                                                   byte[] start,
                                                                                                                   byte[] end)
                                                                                                            throws com.google.protobuf.ServiceException,
                                                                                                                   Throwable

Throws:

com.google.protobuf.ServiceException

Throwable

testAggregationWithReturnValue

public void testAggregationWithReturnValue()
                                    throws Throwable

Throws:

Throwable

testAggregation

public void testAggregation()
                     throws Throwable

Throws:

Throwable

testAggregationWithErrors

public void testAggregationWithErrors()
                               throws Throwable

Throws:

Throwable