public class TestScannerHeartbeatMessages
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
TestScannerHeartbeatMessages.SparseFilter |
Constructor and Description |
---|
TestScannerHeartbeatMessages() |
Modifier and Type | Method and Description |
---|---|
static void |
setUpBeforeClass() |
void |
setupBeforeTest() |
static void |
tearDownAfterClass() |
void |
teardownAfterTest() |
void |
testEquivalenceOfScanWithHeartbeats(Scan scan,
int rowSleepTime,
int cfSleepTime,
boolean sleepBeforeCf)
Test the equivalence of a scan versus the same scan executed when heartbeat messages are
necessary
|
java.util.concurrent.Callable<java.lang.Void> |
testHeartbeatBetweenColumnFamilies()
Test the case that the time limit for scans is reached in between column families
|
java.util.concurrent.Callable<java.lang.Void> |
testHeartbeatBetweenRows()
Test the case that the time limit for the scan is reached after each full row of cells is
fetched.
|
java.util.concurrent.Callable<java.lang.Void> |
testHeartbeatWithSparseFilter()
Test the case that there is a filter which filters most of cells
|
void |
testImportanceOfHeartbeats(java.util.concurrent.Callable<java.lang.Void> testCallable)
Run the test callable when heartbeats are enabled/disabled.
|
void |
testScannerHeartbeatMessages()
Test a variety of scan configurations to ensure that they return the expected Results when
heartbeat messages are necessary.
|
public static void setUpBeforeClass() throws java.lang.Exception
java.lang.Exception
public static void tearDownAfterClass() throws java.lang.Exception
java.lang.Exception
public void setupBeforeTest() throws java.lang.Exception
java.lang.Exception
public void teardownAfterTest() throws java.lang.Exception
java.lang.Exception
public void testScannerHeartbeatMessages() throws java.lang.Exception
java.lang.Exception
public void testImportanceOfHeartbeats(java.util.concurrent.Callable<java.lang.Void> testCallable) throws java.lang.InterruptedException
testCallable
- java.lang.InterruptedException
public java.util.concurrent.Callable<java.lang.Void> testHeartbeatBetweenRows() throws java.lang.Exception
java.lang.Exception
public java.util.concurrent.Callable<java.lang.Void> testHeartbeatBetweenColumnFamilies() throws java.lang.Exception
java.lang.Exception
public java.util.concurrent.Callable<java.lang.Void> testHeartbeatWithSparseFilter() throws java.lang.Exception
java.lang.Exception
public void testEquivalenceOfScanWithHeartbeats(Scan scan, int rowSleepTime, int cfSleepTime, boolean sleepBeforeCf) throws java.lang.Exception
scan
- The scan configuration being testedrowSleepTime
- The time to sleep between fetches of row cellscfSleepTime
- The time to sleep between fetches of column family cellssleepBeforeCf
- set to true when column family sleeps should occur before the cells for
that column family are fetchedjava.lang.Exception