org.apache.giraph.partition

Class TestPartitionStores

java.lang.Object

org.apache.giraph.partition.TestPartitionStores

public class TestPartitionStores
extends Object

Test case for partition stores.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestPartitionStores.EmptyComputation Test compute method that sends each edge a notification of its parents.
static class	TestPartitionStores.MyComputation
static class	TestPartitionStores.TestOutOfCoreMessagesComputation

Constructor Summary

Constructors

Constructor and Description
TestPartitionStores()

Method Summary

Modifier and Type	Method and Description
void	setUp()
void	testDiskBackedPartitionStore()
void	testDiskBackedPartitionStoreAdaptiveOOC()
void	testDiskBackedPartitionStoreComputation()
void	testDiskBackedPartitionStoreMT()
void	testDiskBackedPartitionStoreMTStatic()
void	testDiskBackedPartitionStoreWithByteArrayComputation()
void	testDiskBackedPartitionStoreWithByteArrayPartition()
void	testEdgeCombineWithByteArrayPartition()
void	testEdgeCombineWithSimplePartition()
void	testOutOfCoreMessages()
void	testReadWrite(PartitionStore<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.NullWritable> partitionStore, ImmutableClassesGiraphConfiguration<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.NullWritable> conf) Test reading/writing to/from a partition store
void	testSimplePartitionStore()
void	testUnsafePartitionSerializationClass()

Methods inherited from class java.lang.Object

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

Constructor Detail

TestPartitionStores

public TestPartitionStores()

Method Detail

setUp

public void setUp()

testSimplePartitionStore

public void testSimplePartitionStore()

testUnsafePartitionSerializationClass

public void testUnsafePartitionSerializationClass()
                                           throws IOException

Throws:

IOException

testDiskBackedPartitionStoreWithByteArrayPartition

public void testDiskBackedPartitionStoreWithByteArrayPartition()
                                                        throws IOException

Throws:

IOException

testDiskBackedPartitionStore

public void testDiskBackedPartitionStore()
                                  throws IOException

Throws:

IOException

testDiskBackedPartitionStoreComputation

public void testDiskBackedPartitionStoreComputation()
                                             throws Exception

Throws:

Exception

testDiskBackedPartitionStoreWithByteArrayComputation

public void testDiskBackedPartitionStoreWithByteArrayComputation()
                                                          throws Exception

Throws:

Exception

testDiskBackedPartitionStoreMT

public void testDiskBackedPartitionStoreMT()
                                    throws Exception

Throws:

Exception

testDiskBackedPartitionStoreMTStatic

public void testDiskBackedPartitionStoreMTStatic()
                                          throws Exception

Throws:

Exception

testDiskBackedPartitionStoreAdaptiveOOC

public void testDiskBackedPartitionStoreAdaptiveOOC()
                                             throws Exception

Throws:

Exception

testReadWrite

public void testReadWrite(PartitionStore<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.NullWritable> partitionStore,
                          ImmutableClassesGiraphConfiguration<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.NullWritable> conf)

Test reading/writing to/from a partition store

Parameters:

partitionStore - Partition store to test

conf - Configuration to use

testEdgeCombineWithSimplePartition

public void testEdgeCombineWithSimplePartition()
                                        throws IOException

Throws:

IOException

testEdgeCombineWithByteArrayPartition

public void testEdgeCombineWithByteArrayPartition()
                                           throws IOException

Throws:

IOException

testOutOfCoreMessages

public void testOutOfCoreMessages()
                           throws Exception

Throws:

Exception