public class TestAsyncProcess
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
Timeout |
timeout |
Constructor and Description |
---|
TestAsyncProcess() |
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() |
public static void beforeClass()
public void testSubmit() throws java.lang.Exception
java.lang.Exception
public void testSubmitWithCB() throws java.lang.Exception
java.lang.Exception
public void testSubmitBusyRegion() throws java.lang.Exception
java.lang.Exception
public void testSubmitBusyRegionServer() throws java.lang.Exception
java.lang.Exception
public void testFail() throws java.lang.Exception
java.lang.Exception
public void testSubmitTrue() throws java.io.IOException
java.io.IOException
public void testFailAndSuccess() throws java.lang.Exception
java.lang.Exception
public void testFlush() throws java.lang.Exception
java.lang.Exception
public void testMaxTask() throws java.lang.Exception
java.lang.Exception
public void testHTablePutSuccess() throws java.lang.Exception
java.lang.Exception
public void testHTableFailedPutWithBuffer() throws java.lang.Exception
java.lang.Exception
public void testHTableFailedPutWithoutBuffer() throws java.lang.Exception
java.lang.Exception
public void testHTableFailedPutAndNewPut() throws java.lang.Exception
java.lang.Exception
public void testBatch() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public void testErrorsServers() throws java.io.IOException
java.io.IOException
public void testGlobalErrors() throws java.io.IOException
java.io.IOException
public void testCallQueueTooLarge() throws java.io.IOException
java.io.IOException
public void testThreadCreation() throws java.lang.Exception
java.lang.Exception
public void testReplicaReplicaSuccess() throws java.lang.Exception
java.lang.Exception
public void testReplicaPrimarySuccessWoReplicaCalls() throws java.lang.Exception
java.lang.Exception
public void testReplicaParallelCallsSucceed() throws java.lang.Exception
java.lang.Exception
public void testReplicaPartialReplicaCall() throws java.lang.Exception
java.lang.Exception
public void testReplicaMainFailsBeforeReplicaCalls() throws java.lang.Exception
java.lang.Exception
public void testReplicaReplicaSuccessWithParallelFailures() throws java.lang.Exception
java.lang.Exception
public void testReplicaAllCallsFailForOneRegion() throws java.lang.Exception
java.lang.Exception
public void testWaitForMaximumCurrentTasks() throws java.lang.Exception
java.lang.Exception