Package org.apache.hadoop.hbase.client

Class TestSimpleRequestController

java.lang.Object

org.apache.hadoop.hbase.client.TestSimpleRequestController

@Tag("org.apache.hadoop.hbase.testclassification.ClientTests") @Tag("org.apache.hadoop.hbase.testclassification.SmallTests")
public class TestSimpleRequestController
extends Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
TestSimpleRequestController()

Method Summary

Modifier and Type	Method	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 Details

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.client.RegionInfo HRI1

HRI2

private static final org.apache.hadoop.hbase.client.RegionInfo HRI2

HRI3

private static final org.apache.hadoop.hbase.client.RegionInfo 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 Details

TestSimpleRequestController

public TestSimpleRequestController()

Method Details

testIllegalRequestHeapSize

@Test
public void testIllegalRequestHeapSize()

testIllegalRsTasks

@Test
public void testIllegalRsTasks()

testIllegalRegionTasks

@Test
public void testIllegalRegionTasks()

testIllegalSubmittedSize

@Test
public void testIllegalSubmittedSize()

testIllegalRequestRows

@Test
public void testIllegalRequestRows()

testIllegalArgument

private void testIllegalArgument(String key,
 long value)

createPut

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

testTaskCheckerHost

@Test
public void testTaskCheckerHost()
                         throws IOException

Throws:

IOException

testRequestHeapSizeChecker

@Test
public void testRequestHeapSizeChecker()
                                throws IOException

Throws:

IOException

testRequestRowsChecker

@Test
public void testRequestRowsChecker()
                            throws IOException

Throws:

IOException

testSubmittedSizeChecker

@Test
public void testSubmittedSizeChecker()

testTaskCountChecker

@Test
public void testTaskCountChecker()
                          throws InterruptedIOException

Throws:

InterruptedIOException

testWaitForMaximumCurrentTasks

@Test
public void testWaitForMaximumCurrentTasks()
                                    throws Exception

Throws:

Exception