org.apache.hadoop.hbase.regionserver

Class TestSyncTimeRangeTracker

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestSimpleTimeRangeTracker

org.apache.hadoop.hbase.regionserver.TestSyncTimeRangeTracker

public class TestSyncTimeRangeTracker
extends TestSimpleTimeRangeTracker

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	TestSyncTimeRangeTracker.RandomTestData
(package private) static class	TestSyncTimeRangeTracker.TrtUpdateRunnable

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static int	NUM_KEYS
private static int	NUM_OF_THREADS

Constructor Summary

Constructors

Constructor and Description
TestSyncTimeRangeTracker()

Method Summary

Modifier and Type	Method and Description
protected org.apache.hadoop.hbase.regionserver.TimeRangeTracker	getTimeRangeTracker()
protected org.apache.hadoop.hbase.regionserver.TimeRangeTracker	getTimeRangeTracker(long min, long max)
void	testArriveAtRightAnswer() Run a bunch of threads against a single TimeRangeTracker and ensure we arrive at right range.
void	testConcurrentIncludeTimestampCorrectness() Run a bunch of threads against a single TimeRangeTracker and ensure we arrive at right range.

Methods inherited from class org.apache.hadoop.hbase.regionserver.TestSimpleTimeRangeTracker

testAlwaysDecrementingSetsMaximum, testExtreme, testLegacySerialization, testRangeConstruction, testSerialization, testSimpleInRange, testTimeRangeInitialized, testTimeRangeTrackerNullIsSameAsTimeRangeNull

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

NUM_KEYS

private static final int NUM_KEYS

See Also:

Constant Field Values

NUM_OF_THREADS

private static final int NUM_OF_THREADS

See Also:

Constant Field Values

Constructor Detail

TestSyncTimeRangeTracker

public TestSyncTimeRangeTracker()

Method Detail

getTimeRangeTracker

protected org.apache.hadoop.hbase.regionserver.TimeRangeTracker getTimeRangeTracker()

Overrides:

getTimeRangeTracker in class TestSimpleTimeRangeTracker

getTimeRangeTracker

protected org.apache.hadoop.hbase.regionserver.TimeRangeTracker getTimeRangeTracker(long min,
                                                                                    long max)

Overrides:

getTimeRangeTracker in class TestSimpleTimeRangeTracker

testArriveAtRightAnswer

public void testArriveAtRightAnswer()
                             throws InterruptedException

Run a bunch of threads against a single TimeRangeTracker and ensure we arrive at right range. Here we do ten threads each incrementing over 100k at an offset of the thread index; max is 10 * 10k and min is 0.

Throws:

InterruptedException

testConcurrentIncludeTimestampCorrectness

public void testConcurrentIncludeTimestampCorrectness()

Run a bunch of threads against a single TimeRangeTracker and ensure we arrive at right range. The data chosen is going to ensure that there are lots collisions, i.e, some other threads may already update the value while one tries to update min/max value.