com.bigdata.service

Class TestRangeQuery

java.lang.Object

junit.framework.Assert

junit.framework.TestCase

junit.framework.TestCase2

com.bigdata.btree.AbstractBTreeTestCase

com.bigdata.service.AbstractEmbeddedFederationTestCase

com.bigdata.service.TestRangeQuery

All Implemented Interfaces:

junit.framework.Test

public class TestRangeQuery
extends AbstractEmbeddedFederationTestCase

Test suite for the IRangeQuery API.

Version:

$Id$

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.AbstractEmbeddedFederationTestCase

client, dataService0, dataService1, fed, metadataService

Fields inherited from class com.bigdata.btree.AbstractBTreeTestCase

keyBuilder, log, r

Fields inherited from class junit.framework.TestCase2

_randomType

Constructor Summary

Constructors

Constructor and Description
TestRangeQuery()
TestRangeQuery(String name)

Method Summary

Methods

Modifier and Type	Method and Description
static <E> void	assertSameIteratorAnyOrder(ITuple<E>[] expected, ITupleIterator<E> actual) Verifies that the iterator visits the specified objects in some arbitrary ordering and that the iterator is exhausted once all expected objects have been visited.
static <E> void	assertSameIteratorAnyOrder(String msg, ITuple<E>[] expected, ITupleIterator<E> actual) Verifies that the iterator visits the specified objects in some arbitrary ordering and that the iterator is exhausted once all expected objects have been visited.
static boolean	sameTuple(ITuple<?> expected, ITuple<?> actual) Compares two tuples for equality based on their data (flags, keys, values, deleted marker, and version timestamp).
void	test_parallelRangeIterator() Basic unit tests for the parallel range iterator.
void	test_rangeCount_staticPartitions_01() Range count tests with two (2) static partitions where the successor of a key is found in the next partition (tests the fence post for the mapping of the rangeCount operation over the different partitions).
void	test_rangeQuery_staticPartitions_unbounded_1entry_2partitions_01() Test unbounded range query with one entry in the index and two index partitions.
void	test_rangeQuery_staticPartitions_unbounded_1entry_2partitions_02() Test unbounded range query with one entry in the index and two index partitions.
void	test_rangeQuery_staticPartitions_unbounded_2entries_2partitions_01() Test unbounded range query with two entries in the index and two index partitions.
void	test_rangeQuery_staticPartitions_unbounded_2entries_2partitions_02() Test unbounded range query with two entries in the index and two index partitions.
void	test_rangeQuery_staticPartitions_unbounded_emptyIndex_2partitions() Test unbounded range query with an empty index and two partitions.
void	test_removeAll_limit1_twoPartitions() Test of IRangeQuery.REMOVEALL using a limit (capacity := 1).
void	test_removeAll() Test of IRangeQuery.REMOVEALL using a filter.
void	test_reverseScan() Test the ability to scan a partitioned index in forward and reverse order.

Methods inherited from class com.bigdata.service.AbstractEmbeddedFederationTestCase

assertEquals, assertEquals, assertEquals, assertIndexRegistered, awaitAsynchronousOverflow, getPartitionCount, getProperties, setUp, tearDown

Methods inherited from class com.bigdata.btree.AbstractBTreeTestCase

assertChildKeys, assertEntryCounts, assertKeys, assertKeys, assertKeys, assertSameAbstractNodeData, assertSameBTree, assertSameEntryIterator, assertSameEntryIterator, assertSameIterator, assertSameIterator, assertSameLeaf, assertSameLeafData, assertSameNode, assertSameNodeData, assertSameNodeOrLeaf, assertSameRaba, assertValues, assertValues, doEntryIteratorTest, doInsertKeySequenceTest, doInsertLookupRemoveStressTest, doInsertRandomKeySequenceTest, doInsertRandomKeySequenceTest, doInsertRandomSparseKeySequenceTest, doKnownKeySequenceTest, doRandomIndexOfTest, doRandomKeyInsertTest, doRandomLookupTest, doRemoveStructureStressTest, doSplitTest, doSplitWithDecreasingKeySequence, doSplitWithIncreasingKeySequence, doSplitWithRandomDenseKeySequence, getBTree, getBTree, getKeysAndValues, getRandomKeys, getRandomKeyValues, i2k, nextLong, useRawRecords

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, 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, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

TestRangeQuery

public TestRangeQuery()

TestRangeQuery

public TestRangeQuery(String name)

Method Detail

test_rangeCount_staticPartitions_01

public void test_rangeCount_staticPartitions_01()
                                         throws IOException

Range count tests with two (2) static partitions where the successor of a key is found in the next partition (tests the fence post for the mapping of the rangeCount operation over the different partitions).

Throws:

IOException

test_rangeQuery_staticPartitions_unbounded_emptyIndex_2partitions

public void test_rangeQuery_staticPartitions_unbounded_emptyIndex_2partitions()
                                                                       throws IOException

Test unbounded range query with an empty index and two partitions.

Throws:

IOException

test_rangeQuery_staticPartitions_unbounded_1entry_2partitions_01

public void test_rangeQuery_staticPartitions_unbounded_1entry_2partitions_01()
                                                                      throws IOException

Test unbounded range query with one entry in the index and two index partitions. The entry is in the first partition.

Throws:

IOException

test_rangeQuery_staticPartitions_unbounded_1entry_2partitions_02

public void test_rangeQuery_staticPartitions_unbounded_1entry_2partitions_02()
                                                                      throws IOException

Test unbounded range query with one entry in the index and two index partitions. The entry is in the 2nd partition.

Throws:

IOException

test_rangeQuery_staticPartitions_unbounded_2entries_2partitions_01

public void test_rangeQuery_staticPartitions_unbounded_2entries_2partitions_01()
                                                                        throws IOException

Test unbounded range query with two entries in the index and two index partitions. There is one entry in each partition.

Throws:

IOException

test_rangeQuery_staticPartitions_unbounded_2entries_2partitions_02

public void test_rangeQuery_staticPartitions_unbounded_2entries_2partitions_02()
                                                                        throws IOException

Test unbounded range query with two entries in the index and two index partitions. Both entries are in the 1st index partition and we limit the data service query to one result per query.

Throws:

IOException

test_removeAll_limit1_twoPartitions

public void test_removeAll_limit1_twoPartitions()
                                         throws IOException

Test of IRangeQuery.REMOVEALL using a limit (capacity := 1). This form of the iterator is used to support queue constructs since the delete is performed on the unisolated index. The state of the index is verified afterwards.

Throws:

IOException

test_removeAll

public void test_removeAll()
                    throws IOException

Test of IRangeQuery.REMOVEALL using a filter. Only the even keys are deleted. The state of the index is verified afterwards.

Throws:

IOException

test_reverseScan

public void test_reverseScan()
                      throws IOException

Test the ability to scan a partitioned index in forward and reverse order. The test verifies that index partitions are visited in the correct order, that the chunks within each index partition are visited in the correct order, and that the tuples within each chunk are visited in the correct order. One of the index partitions is deliberately left empty in order to verify that the iterator will correctly cross over an index partition in which the chunked iterator does not visit anything.

Throws:

IOException

test_parallelRangeIterator

public void test_parallelRangeIterator()

Basic unit tests for the parallel range iterator. FIXME write unit tests for the parallel range iterator running across one, one or multiple index partitions, with all of its various flags (including REMOVEALL), when a stale locator exception must be handled, when the iterator is closed early, and when it is closed early with a read consistent tx created on the caller's behalf.

assertSameIteratorAnyOrder

public static <E> void assertSameIteratorAnyOrder(ITuple<E>[] expected,
                                  ITupleIterator<E> actual)

Verifies that the iterator visits the specified objects in some arbitrary ordering and that the iterator is exhausted once all expected objects have been visited. The implementation uses a selection without replacement "pattern".

assertSameIteratorAnyOrder

public static <E> void assertSameIteratorAnyOrder(String msg,
                                  ITuple<E>[] expected,
                                  ITupleIterator<E> actual)

Verifies that the iterator visits the specified objects in some arbitrary ordering and that the iterator is exhausted once all expected objects have been visited. The implementation uses a selection without replacement "pattern".

sameTuple

public static boolean sameTuple(ITuple<?> expected,
                ITuple<?> actual)

Compares two tuples for equality based on their data (flags, keys, values, deleted marker, and version timestamp).

Note: This will fail if you apply it to tuples reported by ITupleIterators whose DELETE flag was different since it verifies the DELETE flag state and that is a property of the iterator NOT the tuple. Whether or not a tuple is deleted is detected using ITuple.isDeletedVersion().

Parameters:

expected -

actual -