com.bigdata.bop.engine

Class TestRunState

java.lang.Object

junit.framework.Assert

junit.framework.TestCase

junit.framework.TestCase2

com.bigdata.bop.engine.TestRunState

All Implemented Interfaces:

junit.framework.Test

public class TestRunState
extends TestCase2

Test suite for RunState.

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 junit.framework.TestCase2

_randomType, log

Constructor Summary

Constructors

Constructor and Description
TestRunState()
TestRunState(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, empty IBindingSet.
protected Map<Integer,AtomicLong>	newMap(int[] ids, long[] vals) Turn two correlated arrays into a Map.
protected Map<Integer,Set>	newMap(int[] ids, Object[][] vals) Turn two correlated arrays into a Map associating Integer keys with Sets.
protected <T> Map<Integer,T>	newMap(int[] ids, T[] vals) Turn two correlated arrays into a Map.
protected Set<Integer>	newSet(int[] a) Turn an array into a Set.
protected <T> Set<T>	newSet(T[] a) Turn an array into a Set.
void	test_ctor_correctRejection() Unit test for the constructor (correct rejection).
void	test_ctor() Unit test for the constructor (correct acceptance).
void	test_deadline_haltOp() Unit test for correct interpretation of a deadline.
void	test_deadline_startOp() Unit test for correct interpretation of a deadline.
void	test_deadline_startQ() Unit test for correct interpretation of a deadline.
void	test_getOperatorRunState_atOnceRequested() Unit test for RunState.getOperatorRunState(int) when some operators require at-once evaluation.
void	test_getOperatorRunState_lastPassRequested() Unit test for RunState.getOperatorRunState(int) when some operators specify the PipelineOp.Annotations#LAST_PASS annotation.
void	test_getOperatorRunState() Unit test for RunState.getOperatorRunState(int)
void	test_lastPassRequested() Unit tests for an operator which requests a final evaluation pass.
void	test_runSingleOperatorQuery() Very simple unit test for the RunState API.
void	test_runTwoOperatorQuery() Run a two operator query where the first operator produces a single output message and the second operator consumes that message.
void	test_startQueryTwice() Unit test verifies that attempting to start a query twice is an error.

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

Methods inherited from class java.lang.Object

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

Constructor Detail

TestRunState

public TestRunState()

TestRunState

public TestRunState(String name)

Parameters:

name -

Method Detail

newBindingSetIterator

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

Return an IAsynchronousIterator that will read a single, empty IBindingSet.

Parameters:

bindingSet - the binding set.

newSet

protected Set<Integer> newSet(int[] a)

Turn an array into a Set.

Parameters:

a - The array.

Returns:

The Set.

newSet

protected <T> Set<T> newSet(T[] a)

Turn an array into a Set.

Parameters:

a - The array.

Returns:

The Set.

newMap

protected Map<Integer,AtomicLong> newMap(int[] ids,
                             long[] vals)

Turn two correlated arrays into a Map.

Parameters:

ids - The keys.

vals - The values.

Returns:

The Map.

newMap

protected <T> Map<Integer,T> newMap(int[] ids,
                        T[] vals)

Turn two correlated arrays into a Map.

Parameters:

ids - The keys.

vals - The values.

Returns:

The Map.

newMap

protected Map<Integer,Set> newMap(int[] ids,
                      Object[][] vals)

Turn two correlated arrays into a Map associating Integer keys with Sets. The 2nd array is two dimension and specifies the set of values for each entry in the Map.

Parameters:

ids - The keys.

vals - The values.

Returns:

The Map.

test_ctor

public void test_ctor()

Unit test for the constructor (correct acceptance).

test_ctor_correctRejection

public void test_ctor_correctRejection()

Unit test for the constructor (correct rejection).

test_getOperatorRunState

public void test_getOperatorRunState()

Unit test for RunState.getOperatorRunState(int)

test_getOperatorRunState_lastPassRequested

public void test_getOperatorRunState_lastPassRequested()

Unit test for RunState.getOperatorRunState(int) when some operators specify the PipelineOp.Annotations#LAST_PASS annotation. TODO Do another variant where there are two such operators. For this variant, we want to make sure that the last pass evaluation for each operator is executed properly.

test_getOperatorRunState_atOnceRequested

public void test_getOperatorRunState_atOnceRequested()

Unit test for RunState.getOperatorRunState(int) when some operators require at-once evaluation.

See Also:

COUNT(DISTINCT) returns no rows rather than ZERO.

test_runSingleOperatorQuery

public void test_runSingleOperatorQuery()
                                 throws TimeoutException,
                                        ExecutionException

Very simple unit test for the RunState API. A query with a single StartOp operator is created and the RunState for that query is directly manipulated in accordance with a simple evaluation schedule for the query (startQuery, startOp, haltOp, allDone). The post-condition of the RunState object is verified after each action.

Throws:

TimeoutException

ExecutionException

RemoteException

test_runTwoOperatorQuery

public void test_runTwoOperatorQuery()
                              throws TimeoutException,
                                     ExecutionException

Run a two operator query where the first operator produces a single output message and the second operator consumes that message.

Throws:

TimeoutException

ExecutionException

test_startQueryTwice

public void test_startQueryTwice()
                          throws TimeoutException,
                                 ExecutionException

Unit test verifies that attempting to start a query twice is an error.

Throws:

TimeoutException

ExecutionException

test_deadline_startQ

public void test_deadline_startQ()
                          throws TimeoutException,
                                 ExecutionException,
                                 InterruptedException

Unit test for correct interpretation of a deadline. There are a series of deadline tests which verify that the deadline is detected by the various action methods (startQuery, startOp, haltOp). For this test, the deadline should be recognized by RunState.startQuery(IChunkMessage).

Throws:

TimeoutException

ExecutionException

InterruptedException

test_deadline_startOp

public void test_deadline_startOp()
                           throws TimeoutException,
                                  ExecutionException,
                                  InterruptedException

Unit test for correct interpretation of a deadline. There are a series of deadline tests which verify that the deadline is detected by the various action methods (startQuery, startOp, haltOp). For this test, the deadline should be recognized by RunState.startOp(IStartOpMessage).

Throws:

TimeoutException

ExecutionException

InterruptedException

test_deadline_haltOp

public void test_deadline_haltOp()
                          throws TimeoutException,
                                 ExecutionException,
                                 InterruptedException

Unit test for correct interpretation of a deadline. There are a series of deadline tests which verify that the deadline is detected by the various action methods (startQuery, startOp, haltOp). For this test, the deadline should recognized by RunState.haltOp(IHaltOpMessage).

Throws:

TimeoutException

ExecutionException

InterruptedException

test_lastPassRequested

public void test_lastPassRequested()
                            throws TimeoutException,
                                   ExecutionException,
                                   InterruptedException

Unit tests for an operator which requests a final evaluation pass.

Throws:

TimeoutException

ExecutionException

InterruptedException

See Also:

PipelineOp.Annotations#LAST_PASS