com.bigdata.bfs

Class TestCopyStream

java.lang.Object

junit.framework.Assert

junit.framework.TestCase

junit.framework.TestCase2

com.bigdata.btree.AbstractBTreeTestCase

com.bigdata.service.AbstractEmbeddedFederationTestCase

com.bigdata.bfs.AbstractRepositoryTestCase

com.bigdata.bfs.TestCopyStream

All Implemented Interfaces:

junit.framework.Test

public class TestCopyStream
extends AbstractRepositoryTestCase

Unit tests for copying streams into the repository and reading them back.

Note: Copying streams is basically a sequence of atomic append operations. TestAppendBlock is responsible for covering the behavior of the atomic append operation, including when spanning multiple index partitions, etc. The unit tests in TestCopyStream are only required to test the logic that breaks down the FileVersionOutputStream into a sequence of atomic append operations.

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.bfs.AbstractRepositoryTestCase

BLOCK_SIZE, repo

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
TestCopyStream()
TestCopyStream(String name)

Method Summary

Methods

Modifier and Type	Method and Description
void	test_copyStream_emptyBlock() Test copy of an empty stream resulting in one block.
void	test_copyStream_fullBlock() Test copy of an stream containing exactly one block's data.
void	test_copyStream_fullBlockPlusOne() Test copy of an stream containing exactly one byte more than a full block of data.
void	test_copyStream_largeRandomStreams() Stress test writing large streams of random length.
void	test_copyStream_largeStream() Test the ability to write a stream onto the index that is automatically partitioned into blocks.
void	test_copyStream_nearlyFullBlock() Test copy of an stream containing exactly one byte less than a full block of data.
void	test_copyStream_smallRandomStreams() Stress test writing small streams of random length (from zero bytes to a full block in length).
void	test_copyStream_smallStream() Copies a short stream onto a file version and reads it back.

Methods inherited from class com.bigdata.bfs.AbstractRepositoryTestCase

getProperties, read, read, setUp, tearDown

Methods inherited from class com.bigdata.service.AbstractEmbeddedFederationTestCase

assertEquals, assertEquals, assertEquals, assertIndexRegistered, awaitAsynchronousOverflow, getPartitionCount

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

TestCopyStream

public TestCopyStream()

TestCopyStream

public TestCopyStream(String name)

Method Detail

test_copyStream_smallStream

public void test_copyStream_smallStream()
                                 throws IOException

Copies a short stream onto a file version and reads it back.

Throws:

IOException

test_copyStream_emptyBlock

public void test_copyStream_emptyBlock()
                                throws IOException

Test copy of an empty stream resulting in one block.

Throws:

IOException

test_copyStream_nearlyFullBlock

public void test_copyStream_nearlyFullBlock()
                                     throws IOException

Test copy of an stream containing exactly one byte less than a full block of data.

Throws:

IOException

test_copyStream_fullBlock

public void test_copyStream_fullBlock()
                               throws IOException

Test copy of an stream containing exactly one block's data.

Throws:

IOException

test_copyStream_fullBlockPlusOne

public void test_copyStream_fullBlockPlusOne()
                                      throws IOException

Test copy of an stream containing exactly one byte more than a full block of data.

Throws:

IOException

test_copyStream_smallRandomStreams

public void test_copyStream_smallRandomStreams()
                                        throws IOException

Stress test writing small streams of random length (from zero bytes to a full block in length).

Throws:

IOException

test_copyStream_largeStream

public void test_copyStream_largeStream()
                                 throws IOException

Test the ability to write a stream onto the index that is automatically partitioned into blocks.

Throws:

IOException

test_copyStream_largeRandomStreams

public void test_copyStream_largeRandomStreams()
                                        throws IOException

Stress test writing large streams of random length.

Throws:

IOException