Package org.apache.hadoop.hbase.regionserver

Class TestSyncTimeRangeTracker

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestSimpleTimeRangeTracker

org.apache.hadoop.hbase.regionserver.TestSyncTimeRangeTracker

@Tag("org.apache.hadoop.hbase.testclassification.RegionServerTests") @Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
public class TestSyncTimeRangeTracker
extends TestSimpleTimeRangeTracker

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field	Description
private static final int	NUM_KEYS
private static final int	NUM_OF_THREADS

Constructor Summary

Constructors

Constructor	Description
TestSyncTimeRangeTracker()

Method Summary

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

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 Details

TestSyncTimeRangeTracker

public TestSyncTimeRangeTracker()

Method Details

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

@Test
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

@Test
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.