Package org.apache.hadoop.hbase.thrift2

Class TestThriftConnection

java.lang.Object

org.apache.hadoop.hbase.thrift2.TestThriftConnection

@Tag("org.apache.hadoop.hbase.testclassification.RestTests") @Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestThriftConnection
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private static final byte[]	FAMILYA
private static final byte[]	FAMILYB
private static final byte[]	FAMILYC
private static final byte[]	FAMILYD
protected static int	httpPort
private static final org.slf4j.Logger	LOG
private static final long	ONE_HOUR
private static final byte[]	QUALIFIER_1
private static final byte[]	QUALIFIER_2
private static final byte[]	ROW_1
private static final byte[]	ROW_2
private static final byte[]	ROW_3
private static final byte[]	ROW_4
protected static final HBaseTestingUtil	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 final long	TS_1
private static final long	TS_2
private static final byte[]	VALUE_1
private static final byte[]	VALUE_2

Constructor Summary

Constructors

Constructor	Description
TestThriftConnection()

Method Summary

Modifier and Type	Method	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()
private void	testGet(org.apache.hadoop.hbase.client.Connection connection, String tableName)
void	testGetClusterId()
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	testThriftAdmin()
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 Details

LOG

private static final org.slf4j.Logger LOG

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 HBaseTestingUtil 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 Details

TestThriftConnection

public TestThriftConnection()

Method Details

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

@BeforeAll
public static void setUp()
                  throws Exception

Throws:

Exception

shutdown

@AfterAll
public static void shutdown()
                     throws Exception

Throws:

Exception

testGetClusterId

@Test
public void testGetClusterId()

testThriftAdmin

@Test
public void testThriftAdmin()
                     throws Exception

Throws:

Exception

testGet

@Test
public void testGet()
             throws Exception

Throws:

Exception

testGet

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

Throws:

IOException

testHBASE22011

@Test
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

@Test
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

@Test
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

@Test
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

@Test
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

@Test
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

@Test
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

@Test
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

@Test
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