com.bigdata.service.ndx.pipeline

Class TestMasterTaskWithSplits

java.lang.Object

junit.framework.Assert

junit.framework.TestCase

junit.framework.TestCase2

com.bigdata.service.ndx.pipeline.AbstractKeyRangeMasterTestCase

com.bigdata.service.ndx.pipeline.TestMasterTaskWithSplits

All Implemented Interfaces:

junit.framework.Test

public class TestMasterTaskWithSplits
extends AbstractKeyRangeMasterTestCase

Stress test using key-range partitioned index (IMetadataIndex), which allows us to test the AbstractMasterTask under split, move, join and other kinds of index partition operations.

Version:

$Id$ FIXME Finish this stress test and enable in TestAll.

Note: KeyBuilder.decodeBigInteger(int, byte[]) has since been written. However, the encoding of a BigInteger as an unsigned byte[] requires a 2 byte signum/runLength prefix. Thus, while KeyBuilder.append(BigInteger) and the decode method might be used to complete this test case, the separator keys will need to be properly formed initially in order to have the leading signum/runlength. The null for the last rightSeparator will also need to be handled specially.

Author:

Bryan Thompson

Nested Class Summary

Nested classes/interfaces inherited from class junit.framework.TestCase2

TestCase2.MyProperties, TestCase2.RandomType

Field Summary

Fields inherited from class com.bigdata.service.ndx.pipeline.AbstractKeyRangeMasterTestCase

dataServices

Fields inherited from class junit.framework.TestCase2

_randomType, log

Constructor Summary

Constructors

Constructor and Description
TestMasterTaskWithSplits()
TestMasterTaskWithSplits(String arg0)

Method Summary

Methods

Modifier and Type	Method and Description
protected byte[]	getSeparatorKey(byte[] leftSeparator, byte[] rightSeparator) Method returns a separator key which lies 1/2 between the given separator keys.
void	test_decodeKey() Unit tests to verify the math used to compute the separator keys.
void	test_getSeparatorKey() FIXME Verify that the separator keys are properly ordered.
void	test_redirectStressTestWithSplits() Stress test for redirects.

Methods inherited from class com.bigdata.service.ndx.pipeline.AbstractKeyRangeMasterTestCase

awaitChunksOut, getRandomDataService, tearDown

Methods inherited from class junit.framework.TestCase2

assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEqualsWithinUlps, assertSameArray, assertSameArray, assertSameBigDecimal, assertSameBigDecimal, assertSameBigInteger, assertSameBigInteger, assertSameIterator, assertSameIterator, assertSameIteratorAnyOrder, assertSameIteratorAnyOrder, assertSameValue, assertSameValue, assertZeroUlps, assertZeroUlps, fail, getInnerCause, getNormalInt, getProjectBuildPath, getProperties, getRandomObject, getRandomObject, getRandomOrder, getRandomString, getTestInputStream, getTestResource, getTestResource, getUlps, getUlps, isDEBUG, isDEBUG, isINFO, isINFO, isInnerCause, logProperties

Methods inherited from class junit.framework.TestCase

assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertFalse, assertFalse, assertNotNull, assertNotNull, assertNotSame, assertNotSame, assertNull, assertNull, assertSame, assertSame, assertTrue, assertTrue, countTestCases, createResult, fail, fail, failNotEquals, failNotSame, failSame, format, getName, run, run, runBare, runTest, setName, setUp, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

TestMasterTaskWithSplits

public TestMasterTaskWithSplits()

TestMasterTaskWithSplits

public TestMasterTaskWithSplits(String arg0)

Parameters:

arg0 -

Method Detail

getSeparatorKey

protected byte[] getSeparatorKey(byte[] leftSeparator,
                     byte[] rightSeparator)

Method returns a separator key which lies 1/2 between the given separator keys. This test suite uses long (64 bit) keys. An empty byte[] corresponds to ZERO (0L). A null, which may only appear as the right separator, corresponds to 2^64. The math is performed using BigInteger.

Parameters:

leftSeparator - The left separator key. The left-most separator key is always an empty byte[] (byte[0]).

rightSeparator - The right separator key. The right-most separator key is always null.

Returns:

A separator key which lies 1/2-way between the given keys.

test_decodeKey

public void test_decodeKey()

Unit tests to verify the math used to compute the separator keys. FIXME This test passes because the assertions are correct, but it only lays out some known points and does not go further to verify that a desired translation between signed longs, unsigned byte[] keys, and BigInteger values is being carried out. [See notes at the top of this file.]

test_getSeparatorKey

public void test_getSeparatorKey()

FIXME Verify that the separator keys are properly ordered. [See notes at the top of this file, but also note that we need to handle the null rightSeparator specially.]

test_redirectStressTestWithSplits

public void test_redirectStressTestWithSplits()
                                       throws InterruptedException,
                                              ExecutionException

Stress test for redirects.

Redirects are stored in an IMetadataIndex so we may test the behavior under SPLITs, MOVEs, or JOINs. The test writes KVO tuples on a master. The master allocates the tuples to output buffers based on the IMetadataIndex mapping. A single thread executes an Op[] schedule while N concurrent producer threads write on the master. The test ends when the schedule is done.

Throws:

InterruptedException

ExecutionException