com.bigdata.bop.join

Class AbstractHashJoinOpTestCase

java.lang.Object

junit.framework.Assert

junit.framework.TestCase

junit.framework.TestCase2

com.bigdata.bop.join.AbstractHashJoinOpTestCase

All Implemented Interfaces:

junit.framework.Test

Direct Known Subclasses:

TestHTreeHashJoinOp, TestJVMHashJoinOp

public abstract class AbstractHashJoinOpTestCase
extends TestCase2

Common base class for hash join with access path unit tests.

Version:

$Id: AbstractHashJoinOpTestCase.java 5499 2011-11-03 19:49:10Z thompsonbry $

Author:

Bryan Thompson

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AbstractHashJoinOpTestCase.JoinSetup Setup for a problem used by many of the join test suites.

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

TestCase2.MyProperties, TestCase2.RandomType

Field Summary

Fields

Modifier and Type	Field and Description
protected AbstractHashJoinOpTestCase.JoinSetup	setup

Fields inherited from class junit.framework.TestCase2

_randomType, log

Constructor Summary

Constructors

Constructor and Description
AbstractHashJoinOpTestCase()
AbstractHashJoinOpTestCase(String name)

Method Summary

Methods

Modifier and Type	Method and Description
protected ThickAsynchronousIterator<IBindingSet[]>	newBindingSetIterator(IBindingSet bindingSet) Return an IAsynchronousIterator that will read a single IBindingSet.
protected abstract PipelineOp	newJoin(BOp[] args, int joinId, IVariable<IV>[] joinVars, Predicate<IV> predOp, UUID queryId, NV... annotations) Return a new join operator instance for the test.
void	setUp()
void	tearDown()
void	test_join_simple_noJoinVars() Unit test for a simple join.
void	test_join_simple_selectOnly_x()
void	test_join_simple_withConstraint()
void	test_join_simple() Unit test for a simple join.
void	test_optionalJoin_and_constraint() Unit tests for optional joins, including a constraint on solutions which join.
void	test_optionalJoin_withAltSink() Unit test for an optional PipelineJoin when the alternative sink is specified (simple variant of the unit test above).

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

Methods inherited from class java.lang.Object

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

Field Detail

setup

protected AbstractHashJoinOpTestCase.JoinSetup setup

Constructor Detail

AbstractHashJoinOpTestCase

public AbstractHashJoinOpTestCase()

AbstractHashJoinOpTestCase

public AbstractHashJoinOpTestCase(String name)

Parameters:

name -

Method Detail

setUp

public void setUp()
           throws Exception

Overrides:

setUp in class junit.framework.TestCase

Throws:

Exception

tearDown

public void tearDown()
              throws Exception

Overrides:

tearDown in class junit.framework.TestCase

Throws:

Exception

newBindingSetIterator

protected ThickAsynchronousIterator<IBindingSet[]> newBindingSetIterator(IBindingSet bindingSet)

Return an IAsynchronousIterator that will read a single IBindingSet.

Parameters:

bindingSet - the binding set.

newJoin

protected abstract PipelineOp newJoin(BOp[] args,
                 int joinId,
                 IVariable<IV>[] joinVars,
                 Predicate<IV> predOp,
                 UUID queryId,
                 NV... annotations)

Return a new join operator instance for the test.

Parameters:

args -

joinId -

joinVars -

predOp -

queryId -

annotations -

Returns:

test_join_simple

public void test_join_simple()
                      throws InterruptedException,
                             ExecutionException

Unit test for a simple join. There are two source solutions. Each binds the join variable (there is only one join variable, which is [x]). The access path is run once and visits two elements, yielding as-bound solutions. The hash map containing the buffered source solutions is probed and the as-bound solutions which join are written out.

Throws:

InterruptedException

ExecutionException

test_join_simple_noJoinVars

public void test_join_simple_noJoinVars()
                                 throws InterruptedException,
                                        ExecutionException

Unit test for a simple join. There are two source solutions. Each binds the join variable (there is only one join variable, which is [x]). The access path is run once and visits two elements, yielding as-bound solutions. The hash map containing the buffered source solutions is probed and the as-bound solutions which join are written out.

For this variant, there are no join variables. We should get exactly the same solutions but the join will do more work.

Throws:

InterruptedException

ExecutionException

test_join_simple_withConstraint

public void test_join_simple_withConstraint()
                                     throws InterruptedException,
                                            ExecutionException

Throws:

InterruptedException

ExecutionException

test_join_simple_selectOnly_x

public void test_join_simple_selectOnly_x()
                                   throws InterruptedException,
                                          ExecutionException

Throws:

InterruptedException

ExecutionException

test_optionalJoin_and_constraint

public void test_optionalJoin_and_constraint()
                                      throws InterruptedException,
                                             ExecutionException

Unit tests for optional joins, including a constraint on solutions which join.

Throws:

ExecutionException

InterruptedException

test_optionalJoin_withAltSink

public void test_optionalJoin_withAltSink()
                                   throws InterruptedException,
                                          ExecutionException

Unit test for an optional PipelineJoin when the alternative sink is specified (simple variant of the unit test above).

Throws:

InterruptedException

ExecutionException