org.apache.hadoop.hbase.regionserver

Class TestServerCustomProtocol

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestServerCustomProtocol

public class TestServerCustomProtocol
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestServerCustomProtocol.PingHandler

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
(package private) static String	HELLO
private static org.slf4j.Logger	LOG
(package private) static String	NOBODY
private static byte[]	ROW_A
private static byte[]	ROW_AB
private static byte[]	ROW_B
private static byte[]	ROW_BC
private static byte[]	ROW_C
private static byte[]	TEST_FAMILY
private static org.apache.hadoop.hbase.TableName	TEST_TABLE
private static HBaseTestingUtility	util
(package private) static String	WHOAREYOU

Constructor Summary

Constructors

Constructor and Description
TestServerCustomProtocol()

Method Summary

Modifier and Type	Method and Description
void	after()
void	before()
private Map<byte[],String>	compoundOfHelloAndPing(org.apache.hadoop.hbase.client.Table table, byte[] start, byte[] end)
private static String	doPing(org.apache.hadoop.hbase.coprocessor.protobuf.generated.PingProtos.PingService instance)
private Map<byte[],String>	hello(org.apache.hadoop.hbase.client.Table table, String send)
private Map<byte[],String>	hello(org.apache.hadoop.hbase.client.Table table, String send, byte[] start, byte[] end)
private Map<byte[],String>	hello(org.apache.hadoop.hbase.client.Table table, String send, String response)
private Map<byte[],String>	noop(org.apache.hadoop.hbase.client.Table table, byte[] start, byte[] end)
private Map<byte[],String>	ping(org.apache.hadoop.hbase.client.Table table, byte[] start, byte[] end)
static void	setupBeforeClass()
static void	tearDownAfterClass()
void	testCompoundCall()
void	testEmptyReturnType()
void	testNullCall()
void	testNullReturn()
void	testRowRange()
void	testSingleMethod()
void	testSingleProxy()
private void	verifyRegionResults(org.apache.hadoop.hbase.client.RegionLocator table, Map<byte[],String> results, byte[] row)
private void	verifyRegionResults(org.apache.hadoop.hbase.client.RegionLocator regionLocator, Map<byte[],String> results, String expected, byte[] row)

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

WHOAREYOU

static final String WHOAREYOU

See Also:

Constant Field Values

NOBODY

static final String NOBODY

See Also:

Constant Field Values

HELLO

static final String HELLO

See Also:

Constant Field Values

TEST_TABLE

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

TEST_FAMILY

private static final byte[] TEST_FAMILY

ROW_A

private static final byte[] ROW_A

ROW_B

private static final byte[] ROW_B

ROW_C

private static final byte[] ROW_C

ROW_AB

private static final byte[] ROW_AB

ROW_BC

private static final byte[] ROW_BC

util

private static HBaseTestingUtility util

Constructor Detail

TestServerCustomProtocol

public TestServerCustomProtocol()

Method Detail

setupBeforeClass

public static void setupBeforeClass()
                             throws Exception

Throws:

Exception

before

public void before()
            throws Exception

Throws:

Exception

after

public void after()
           throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

testSingleProxy

public void testSingleProxy()
                     throws Throwable

Throws:

Throwable

hello

private Map<byte[],String> hello(org.apache.hadoop.hbase.client.Table table,
                                 String send,
                                 String response)
                          throws com.google.protobuf.ServiceException,
                                 Throwable

Throws:

com.google.protobuf.ServiceException

Throwable

hello

private Map<byte[],String> hello(org.apache.hadoop.hbase.client.Table table,
                                 String send)
                          throws com.google.protobuf.ServiceException,
                                 Throwable

Throws:

com.google.protobuf.ServiceException

Throwable

hello

private Map<byte[],String> hello(org.apache.hadoop.hbase.client.Table table,
                                 String send,
                                 byte[] start,
                                 byte[] end)
                          throws com.google.protobuf.ServiceException,
                                 Throwable

Throws:

com.google.protobuf.ServiceException

Throwable

compoundOfHelloAndPing

private Map<byte[],String> compoundOfHelloAndPing(org.apache.hadoop.hbase.client.Table table,
                                                  byte[] start,
                                                  byte[] end)
                                           throws com.google.protobuf.ServiceException,
                                                  Throwable

Throws:

com.google.protobuf.ServiceException

Throwable

noop

private Map<byte[],String> noop(org.apache.hadoop.hbase.client.Table table,
                                byte[] start,
                                byte[] end)
                         throws com.google.protobuf.ServiceException,
                                Throwable

Throws:

com.google.protobuf.ServiceException

Throwable

testSingleMethod

public void testSingleMethod()
                      throws Throwable

Throws:

Throwable

testRowRange

public void testRowRange()
                  throws Throwable

Throws:

Throwable

ping

private Map<byte[],String> ping(org.apache.hadoop.hbase.client.Table table,
                                byte[] start,
                                byte[] end)
                         throws com.google.protobuf.ServiceException,
                                Throwable

Throws:

com.google.protobuf.ServiceException

Throwable

doPing

private static String doPing(org.apache.hadoop.hbase.coprocessor.protobuf.generated.PingProtos.PingService instance)
                      throws IOException

Throws:

IOException

testCompoundCall

public void testCompoundCall()
                      throws Throwable

Throws:

Throwable

testNullCall

public void testNullCall()
                  throws Throwable

Throws:

Throwable

testNullReturn

public void testNullReturn()
                    throws Throwable

Throws:

Throwable

testEmptyReturnType

public void testEmptyReturnType()
                         throws Throwable

Throws:

Throwable

verifyRegionResults

private void verifyRegionResults(org.apache.hadoop.hbase.client.RegionLocator table,
                                 Map<byte[],String> results,
                                 byte[] row)
                          throws Exception

Throws:

Exception

verifyRegionResults

private void verifyRegionResults(org.apache.hadoop.hbase.client.RegionLocator regionLocator,
                                 Map<byte[],String> results,
                                 String expected,
                                 byte[] row)
                          throws Exception

Throws:

Exception