org.apache.hadoop.hbase.trace

Class IntegrationTestSendTraceRequests

java.lang.Object

org.apache.hadoop.hbase.util.AbstractHBaseTool

org.apache.hadoop.hbase.trace.IntegrationTestSendTraceRequests

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.util.Tool

public class IntegrationTestSendTraceRequests
extends org.apache.hadoop.hbase.util.AbstractHBaseTool

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.util.AbstractHBaseTool

org.apache.hadoop.hbase.util.AbstractHBaseTool.OptionsOrderComparator

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.hadoop.hbase.client.Admin	admin
static String	CF_ARG
static String	COLUMN_FAMILY_DEFAULT
private byte[]	familyName
private Random	random
private org.apache.hadoop.hbase.trace.SpanReceiverHost	receiverHost
static String	TABLE_ARG
static String	TABLE_NAME_DEFAULT
private org.apache.hadoop.hbase.TableName	tableName
private IntegrationTestingUtility	util

Fields inherited from class org.apache.hadoop.hbase.util.AbstractHBaseTool

cmdLineArgs, conf, EXIT_FAILURE, EXIT_SUCCESS, LONG_HELP_OPTION, options, SHORT_HELP_OPTION

Constructor Summary

Constructors

Constructor and Description
IntegrationTestSendTraceRequests()

Method Summary

Modifier and Type	Method and Description
protected void	addOptions()
private void	createTable()
private IntegrationTestingUtility	createUtil()
private void	deleteTable()
private void	doGets(ExecutorService service, LinkedBlockingQueue<Long> rowKeys)
private void	doScans(ExecutorService service, LinkedBlockingQueue<Long> rks)
int	doWork()
private LinkedBlockingQueue<Long>	insertData()
void	internalDoWork()
static void	main(String[] args)
void	processOptions(org.apache.hbase.thirdparty.org.apache.commons.cli.CommandLine cmd)
private void	setupReceiver()

Methods inherited from class org.apache.hadoop.hbase.util.AbstractHBaseTool

addOption, addOptNoArg, addOptNoArg, addOptWithArg, addOptWithArg, addRequiredOption, addRequiredOptWithArg, addRequiredOptWithArg, doStaticMain, getConf, getOptionAsDouble, getOptionAsInt, getOptionAsLong, newParser, parseArgs, parseInt, parseLong, printUsage, printUsage, processOldArgs, run, setConf

Methods inherited from class java.lang.Object

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

Field Detail

TABLE_ARG

public static final String TABLE_ARG

See Also:

Constant Field Values

CF_ARG

public static final String CF_ARG

See Also:

Constant Field Values

TABLE_NAME_DEFAULT

public static final String TABLE_NAME_DEFAULT

See Also:

Constant Field Values

COLUMN_FAMILY_DEFAULT

public static final String COLUMN_FAMILY_DEFAULT

See Also:

Constant Field Values

tableName

private org.apache.hadoop.hbase.TableName tableName

familyName

private byte[] familyName

util

private IntegrationTestingUtility util

random

private Random random

admin

private org.apache.hadoop.hbase.client.Admin admin

receiverHost

private org.apache.hadoop.hbase.trace.SpanReceiverHost receiverHost

Constructor Detail

IntegrationTestSendTraceRequests

public IntegrationTestSendTraceRequests()

Method Detail

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

addOptions

protected void addOptions()

Specified by:

addOptions in class org.apache.hadoop.hbase.util.AbstractHBaseTool

processOptions

public void processOptions(org.apache.hbase.thirdparty.org.apache.commons.cli.CommandLine cmd)

Specified by:

processOptions in class org.apache.hadoop.hbase.util.AbstractHBaseTool

doWork

public int doWork()
           throws Exception

Specified by:

doWork in class org.apache.hadoop.hbase.util.AbstractHBaseTool

Throws:

Exception

internalDoWork

public void internalDoWork()
                    throws Exception

Throws:

Exception

doScans

private void doScans(ExecutorService service,
                     LinkedBlockingQueue<Long> rks)

doGets

private void doGets(ExecutorService service,
                    LinkedBlockingQueue<Long> rowKeys)
             throws IOException

Throws:

IOException

createTable

private void createTable()
                  throws IOException

Throws:

IOException

deleteTable

private void deleteTable()
                  throws IOException

Throws:

IOException

insertData

private LinkedBlockingQueue<Long> insertData()
                                      throws IOException,
                                             InterruptedException

Throws:

IOException

InterruptedException

createUtil

private IntegrationTestingUtility createUtil()
                                      throws Exception

Throws:

Exception

setupReceiver

private void setupReceiver()