org.apache.hadoop.hbase.client

Class TestSimpleRequestController

java.lang.Object

org.apache.hadoop.hbase.client.TestSimpleRequestController

public class TestSimpleRequestController
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static byte[]	DUMMY_BYTES_1
private static byte[]	DUMMY_BYTES_2
private static byte[]	DUMMY_BYTES_3
private static org.apache.hadoop.hbase.TableName	DUMMY_TABLE
private static org.apache.hadoop.hbase.HRegionInfo	HRI1
private static org.apache.hadoop.hbase.HRegionInfo	HRI2
private static org.apache.hadoop.hbase.HRegionInfo	HRI3
private static org.apache.hadoop.hbase.HRegionLocation	LOC1
private static org.apache.hadoop.hbase.HRegionLocation	LOC2
private static org.apache.hadoop.hbase.HRegionLocation	LOC3
private static org.apache.hadoop.hbase.ServerName	SN
private static org.apache.hadoop.hbase.ServerName	SN2

Constructor Summary

Constructors

Constructor and Description
TestSimpleRequestController()

Method Summary

Modifier and Type	Method and Description
private static org.apache.hadoop.hbase.client.Put	createPut(long maxHeapSizePerRequest)
private void	testIllegalArgument(String key, long value)
void	testIllegalRegionTasks()
void	testIllegalRequestHeapSize()
void	testIllegalRequestRows()
void	testIllegalRsTasks()
void	testIllegalSubmittedSize()
void	testRequestHeapSizeChecker()
void	testRequestRowsChecker()
void	testSubmittedSizeChecker()
void	testTaskCheckerHost()
void	testTaskCountChecker()
void	testWaitForMaximumCurrentTasks()

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

DUMMY_TABLE

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

DUMMY_BYTES_1

private static final byte[] DUMMY_BYTES_1

DUMMY_BYTES_2

private static final byte[] DUMMY_BYTES_2

DUMMY_BYTES_3

private static final byte[] DUMMY_BYTES_3

SN

private static final org.apache.hadoop.hbase.ServerName SN

SN2

private static final org.apache.hadoop.hbase.ServerName SN2

HRI1

private static final org.apache.hadoop.hbase.HRegionInfo HRI1

HRI2

private static final org.apache.hadoop.hbase.HRegionInfo HRI2

HRI3

private static final org.apache.hadoop.hbase.HRegionInfo HRI3

LOC1

private static final org.apache.hadoop.hbase.HRegionLocation LOC1

LOC2

private static final org.apache.hadoop.hbase.HRegionLocation LOC2

LOC3

private static final org.apache.hadoop.hbase.HRegionLocation LOC3

Constructor Detail

TestSimpleRequestController

public TestSimpleRequestController()

Method Detail

testIllegalRequestHeapSize

public void testIllegalRequestHeapSize()

testIllegalRsTasks

public void testIllegalRsTasks()

testIllegalRegionTasks

public void testIllegalRegionTasks()

testIllegalSubmittedSize

public void testIllegalSubmittedSize()

testIllegalRequestRows

public void testIllegalRequestRows()

testIllegalArgument

private void testIllegalArgument(String key,
                                 long value)

createPut

private static org.apache.hadoop.hbase.client.Put createPut(long maxHeapSizePerRequest)

testTaskCheckerHost

public void testTaskCheckerHost()
                         throws IOException

Throws:

IOException

testRequestHeapSizeChecker

public void testRequestHeapSizeChecker()
                                throws IOException

Throws:

IOException

testRequestRowsChecker

public void testRequestRowsChecker()
                            throws IOException

Throws:

IOException

testSubmittedSizeChecker

public void testSubmittedSizeChecker()

testTaskCountChecker

public void testTaskCountChecker()
                          throws InterruptedIOException

Throws:

InterruptedIOException

testWaitForMaximumCurrentTasks

public void testWaitForMaximumCurrentTasks()
                                    throws Exception

Throws:

Exception