org.apache.hadoop.hbase.client

Class TestAsyncProcess

java.lang.Object

org.apache.hadoop.hbase.client.TestAsyncProcess

public class TestAsyncProcess
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
Timeout	timeout

Constructor Summary

Constructors

Constructor and Description
TestAsyncProcess()

Method Summary

Modifier and Type	Method and Description
static void	beforeClass()
void	testBatch()
void	testCallQueueTooLarge()
void	testErrorsServers()
void	testFail()
void	testFailAndSuccess()
void	testFlush()
void	testGlobalErrors()
void	testHTableFailedPutAndNewPut()
void	testHTableFailedPutWithBuffer()
void	testHTableFailedPutWithoutBuffer()
void	testHTablePutSuccess()
void	testMaxTask()
void	testReplicaAllCallsFailForOneRegion()
void	testReplicaMainFailsBeforeReplicaCalls()
void	testReplicaParallelCallsSucceed()
void	testReplicaPartialReplicaCall()
void	testReplicaPrimarySuccessWoReplicaCalls()
void	testReplicaReplicaSuccess()
void	testReplicaReplicaSuccessWithParallelFailures()
void	testSubmit()
void	testSubmitBusyRegion()
void	testSubmitBusyRegionServer()
void	testSubmitTrue()
void	testSubmitWithCB()
void	testThreadCreation() This test simulates multiple regions on 2 servers.
void	testWaitForMaximumCurrentTasks()

Methods inherited from class java.lang.Object

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

Field Detail

timeout

public Timeout timeout

Constructor Detail

TestAsyncProcess

public TestAsyncProcess()

Method Detail

beforeClass

public static void beforeClass()

testSubmit

public void testSubmit()
                throws java.lang.Exception

Throws:

java.lang.Exception

testSubmitWithCB

public void testSubmitWithCB()
                      throws java.lang.Exception

Throws:

java.lang.Exception

testSubmitBusyRegion

public void testSubmitBusyRegion()
                          throws java.lang.Exception

Throws:

java.lang.Exception

testSubmitBusyRegionServer

public void testSubmitBusyRegionServer()
                                throws java.lang.Exception

Throws:

java.lang.Exception

testFail

public void testFail()
              throws java.lang.Exception

Throws:

java.lang.Exception

testSubmitTrue

public void testSubmitTrue()
                    throws java.io.IOException

Throws:

java.io.IOException

testFailAndSuccess

public void testFailAndSuccess()
                        throws java.lang.Exception

Throws:

java.lang.Exception

testFlush

public void testFlush()
               throws java.lang.Exception

Throws:

java.lang.Exception

testMaxTask

public void testMaxTask()
                 throws java.lang.Exception

Throws:

java.lang.Exception

testHTablePutSuccess

public void testHTablePutSuccess()
                          throws java.lang.Exception

Throws:

java.lang.Exception

testHTableFailedPutWithBuffer

public void testHTableFailedPutWithBuffer()
                                   throws java.lang.Exception

Throws:

java.lang.Exception

testHTableFailedPutWithoutBuffer

public void testHTableFailedPutWithoutBuffer()
                                      throws java.lang.Exception

Throws:

java.lang.Exception

testHTableFailedPutAndNewPut

public void testHTableFailedPutAndNewPut()
                                  throws java.lang.Exception

Throws:

java.lang.Exception

testBatch

public void testBatch()
               throws java.io.IOException,
                      java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

testErrorsServers

public void testErrorsServers()
                       throws java.io.IOException

Throws:

java.io.IOException

testGlobalErrors

public void testGlobalErrors()
                      throws java.io.IOException

Throws:

java.io.IOException

testCallQueueTooLarge

public void testCallQueueTooLarge()
                           throws java.io.IOException

Throws:

java.io.IOException

testThreadCreation

public void testThreadCreation()
                        throws java.lang.Exception

This test simulates multiple regions on 2 servers. We should have 2 multi requests and 2 threads: 1 per server, this whatever the number of regions.

Throws:

java.lang.Exception

testReplicaReplicaSuccess

public void testReplicaReplicaSuccess()
                               throws java.lang.Exception

Throws:

java.lang.Exception

testReplicaPrimarySuccessWoReplicaCalls

public void testReplicaPrimarySuccessWoReplicaCalls()
                                             throws java.lang.Exception

Throws:

java.lang.Exception

testReplicaParallelCallsSucceed

public void testReplicaParallelCallsSucceed()
                                     throws java.lang.Exception

Throws:

java.lang.Exception

testReplicaPartialReplicaCall

public void testReplicaPartialReplicaCall()
                                   throws java.lang.Exception

Throws:

java.lang.Exception

testReplicaMainFailsBeforeReplicaCalls

public void testReplicaMainFailsBeforeReplicaCalls()
                                            throws java.lang.Exception

Throws:

java.lang.Exception

testReplicaReplicaSuccessWithParallelFailures

public void testReplicaReplicaSuccessWithParallelFailures()
                                                   throws java.lang.Exception

Throws:

java.lang.Exception

testReplicaAllCallsFailForOneRegion

public void testReplicaAllCallsFailForOneRegion()
                                         throws java.lang.Exception

Throws:

java.lang.Exception

testWaitForMaximumCurrentTasks

public void testWaitForMaximumCurrentTasks()
                                    throws java.lang.Exception

Throws:

java.lang.Exception