org.apache.hadoop.hbase.thrift2

Class TestThriftConnection

java.lang.Object

org.apache.hadoop.hbase.thrift2.TestThriftConnection

public class TestThriftConnection
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static byte[]	FAMILYA
private static byte[]	FAMILYB
private static byte[]	FAMILYC
private static byte[]	FAMILYD
protected static int	httpPort
private static org.slf4j.Logger	LOG
private static long	ONE_HOUR
private static byte[]	QUALIFIER_1
private static byte[]	QUALIFIER_2
private static byte[]	ROW_1
private static byte[]	ROW_2
private static byte[]	ROW_3
private static byte[]	ROW_4
protected static HBaseTestingUtility	TEST_UTIL
private static org.apache.hadoop.hbase.client.Admin	thriftAdmin
protected static org.apache.hadoop.hbase.client.Connection	thriftConnection
protected static org.apache.hadoop.hbase.client.Connection	thriftHttpConnection
protected static org.apache.hadoop.hbase.thrift2.ThriftServer	thriftHttpServer
protected static int	thriftPort
protected static org.apache.hadoop.hbase.thrift2.ThriftServer	thriftServer
private static long	TS_1
private static long	TS_2
private static byte[]	VALUE_1
private static byte[]	VALUE_2

Constructor Summary

Constructors

Constructor and Description
TestThriftConnection()

Method Summary

Modifier and Type	Method and Description
private static org.apache.hadoop.hbase.client.Connection	createConnection(int port, boolean useHttp)
private org.apache.hadoop.hbase.client.TableDescriptor	createTable(org.apache.hadoop.hbase.client.Admin admin, String tableName)
static void	setUp()
static void	shutdown()
private static org.apache.hadoop.hbase.thrift2.ThriftServer	startThriftServer(int port, boolean useHttp)
void	testCheckAndDelete()
void	testCheckAndDelete(org.apache.hadoop.hbase.client.Connection connection, String tableName)
void	testDelete()
void	testDelete(org.apache.hadoop.hbase.client.Connection connection, String tableName)
void	testGet()
void	testGet(org.apache.hadoop.hbase.client.Connection connection, String tableName)
void	testHBASE22011()
void	testHBASE22011(org.apache.hadoop.hbase.client.Connection connection, String tableName)
void	testIteratorScaner()
void	testIteratorScanner(org.apache.hadoop.hbase.client.Connection connection, String tableName)
void	testMultiGet()
void	testMultiGet(org.apache.hadoop.hbase.client.Connection connection, String tableName)
void	testPut()
void	testPut(org.apache.hadoop.hbase.client.Connection connection, String tableName)
void	testReverseScan()
void	testReverseScan(org.apache.hadoop.hbase.client.Connection connection, String tableName)
void	testScanner()
void	testScanner(org.apache.hadoop.hbase.client.Connection connection, String tableName)
void	testScanWithFilters()
private void	testScanWithFilters(org.apache.hadoop.hbase.client.Connection connection, String tableName)
void	testThrfitAdmin()
private void	testThriftAdmin(org.apache.hadoop.hbase.client.Connection connection, String namespace, String table)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOG

private static final org.slf4j.Logger LOG

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

FAMILYA

private static final byte[] FAMILYA

FAMILYB

private static final byte[] FAMILYB

FAMILYC

private static final byte[] FAMILYC

FAMILYD

private static final byte[] FAMILYD

ROW_1

private static final byte[] ROW_1

ROW_2

private static final byte[] ROW_2

ROW_3

private static final byte[] ROW_3

ROW_4

private static final byte[] ROW_4

QUALIFIER_1

private static final byte[] QUALIFIER_1

QUALIFIER_2

private static final byte[] QUALIFIER_2

VALUE_1

private static final byte[] VALUE_1

VALUE_2

private static final byte[] VALUE_2

ONE_HOUR

private static final long ONE_HOUR

See Also:

Constant Field Values

TS_2

private static final long TS_2

TS_1

private static final long TS_1

TEST_UTIL

protected static final HBaseTestingUtility TEST_UTIL

thriftServer

protected static org.apache.hadoop.hbase.thrift2.ThriftServer thriftServer

thriftHttpServer

protected static org.apache.hadoop.hbase.thrift2.ThriftServer thriftHttpServer

thriftPort

protected static int thriftPort

httpPort

protected static int httpPort

thriftConnection

protected static org.apache.hadoop.hbase.client.Connection thriftConnection

thriftHttpConnection

protected static org.apache.hadoop.hbase.client.Connection thriftHttpConnection

thriftAdmin

private static org.apache.hadoop.hbase.client.Admin thriftAdmin

Constructor Detail

TestThriftConnection

public TestThriftConnection()

Method Detail

startThriftServer

private static org.apache.hadoop.hbase.thrift2.ThriftServer startThriftServer(int port,
                                                                              boolean useHttp)

createConnection

private static org.apache.hadoop.hbase.client.Connection createConnection(int port,
                                                                          boolean useHttp)
                                                                   throws IOException

Throws:

IOException

setUp

public static void setUp()
                  throws Exception

Throws:

Exception

shutdown

public static void shutdown()
                     throws Exception

Throws:

Exception

testThrfitAdmin

public void testThrfitAdmin()
                     throws Exception

Throws:

Exception

testGet

public void testGet()
             throws Exception

Throws:

Exception

testGet

public void testGet(org.apache.hadoop.hbase.client.Connection connection,
                    String tableName)
             throws IOException

Throws:

IOException

testHBASE22011

public void testHBASE22011()
                    throws Exception

Throws:

Exception

testHBASE22011

public void testHBASE22011(org.apache.hadoop.hbase.client.Connection connection,
                           String tableName)
                    throws IOException

Throws:

IOException

testMultiGet

public void testMultiGet()
                  throws Exception

Throws:

Exception

testMultiGet

public void testMultiGet(org.apache.hadoop.hbase.client.Connection connection,
                         String tableName)
                  throws Exception

Throws:

Exception

testPut

public void testPut()
             throws Exception

Throws:

Exception

testPut

public void testPut(org.apache.hadoop.hbase.client.Connection connection,
                    String tableName)
             throws IOException

Throws:

IOException

testDelete

public void testDelete()
                throws Exception

Throws:

Exception

testDelete

public void testDelete(org.apache.hadoop.hbase.client.Connection connection,
                       String tableName)
                throws IOException

Throws:

IOException

testScanner

public void testScanner()
                 throws Exception

Throws:

Exception

testScanner

public void testScanner(org.apache.hadoop.hbase.client.Connection connection,
                        String tableName)
                 throws IOException

Throws:

IOException

testCheckAndDelete

public void testCheckAndDelete()
                        throws Exception

Throws:

Exception

testCheckAndDelete

public void testCheckAndDelete(org.apache.hadoop.hbase.client.Connection connection,
                               String tableName)
                        throws IOException

Throws:

IOException

testIteratorScaner

public void testIteratorScaner()
                        throws Exception

Throws:

Exception

testIteratorScanner

public void testIteratorScanner(org.apache.hadoop.hbase.client.Connection connection,
                                String tableName)
                         throws IOException

Throws:

IOException

testReverseScan

public void testReverseScan()
                     throws Exception

Throws:

Exception

testReverseScan

public void testReverseScan(org.apache.hadoop.hbase.client.Connection connection,
                            String tableName)
                     throws IOException

Throws:

IOException

testScanWithFilters

public void testScanWithFilters()
                         throws Exception

Throws:

Exception

testScanWithFilters

private void testScanWithFilters(org.apache.hadoop.hbase.client.Connection connection,
                                 String tableName)
                          throws IOException

Throws:

IOException

createTable

private org.apache.hadoop.hbase.client.TableDescriptor createTable(org.apache.hadoop.hbase.client.Admin admin,
                                                                   String tableName)
                                                            throws IOException

Throws:

IOException

testThriftAdmin

private void testThriftAdmin(org.apache.hadoop.hbase.client.Connection connection,
                             String namespace,
                             String table)
                      throws Exception

Throws:

Exception