org.apache.hadoop.hbase.thrift

Class HBaseThriftTestingUtility

java.lang.Object

org.apache.hadoop.hbase.thrift.HBaseThriftTestingUtility

public class HBaseThriftTestingUtility
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG
private int	port
private org.apache.hadoop.hbase.thrift.ThriftServer	thriftServer
private Exception	thriftServerException
private Thread	thriftServerThread

Constructor Summary

Constructors

Constructor and Description
HBaseThriftTestingUtility()

Method Summary

Modifier and Type	Method and Description
private org.apache.hadoop.hbase.thrift.ThriftServer	createThriftServer(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.thrift.ThriftMetrics.ThriftServerType type) create a new thrift server
int	getServerPort()
void	startThriftServer(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.thrift.ThriftMetrics.ThriftServerType type) start thrift server
private void	startThriftServerThread(String[] args)
void	stopThriftServer()
private void	waitForThriftServer()

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

thriftServerThread

private Thread thriftServerThread

thriftServerException

private volatile Exception thriftServerException

thriftServer

private org.apache.hadoop.hbase.thrift.ThriftServer thriftServer

port

private int port

Constructor Detail

HBaseThriftTestingUtility

public HBaseThriftTestingUtility()

Method Detail

getServerPort

public int getServerPort()

startThriftServer

public void startThriftServer(org.apache.hadoop.conf.Configuration conf,
                              org.apache.hadoop.hbase.thrift.ThriftMetrics.ThriftServerType type)
                       throws Exception

start thrift server

Parameters:

conf - configuration

type - the type of thrift server

Throws:

Exception - When starting the thrift server fails.

startThriftServerThread

private void startThriftServerThread(String[] args)

createThriftServer

private org.apache.hadoop.hbase.thrift.ThriftServer createThriftServer(org.apache.hadoop.conf.Configuration conf,
                                                                       org.apache.hadoop.hbase.thrift.ThriftMetrics.ThriftServerType type)

create a new thrift server

Parameters:

conf - configuration

type - the type of thrift server

Returns:

the instance of ThriftServer

waitForThriftServer

private void waitForThriftServer()
                          throws Exception

Throws:

Exception

stopThriftServer

public void stopThriftServer()
                      throws Exception

Throws:

Exception