org.apache.giraph.io

Class TestTextDoubleDoubleAdjacencyListVertexInputFormat

java.lang.Object

org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable<I,V,E>

org.apache.giraph.io.GiraphInputFormat<I,V,E>

org.apache.giraph.io.VertexInputFormat<I,V,E>

org.apache.giraph.io.formats.TextVertexInputFormat<I,V,E>

org.apache.giraph.io.formats.AdjacencyListTextVertexInputFormat<org.apache.hadoop.io.Text,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.DoubleWritable>

org.apache.giraph.io.formats.TextDoubleDoubleAdjacencyListVertexInputFormat

org.apache.giraph.io.TestTextDoubleDoubleAdjacencyListVertexInputFormat

All Implemented Interfaces:

GiraphConfigurationSettable<org.apache.hadoop.io.Text,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.DoubleWritable>, ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.Text,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.DoubleWritable>

public class TestTextDoubleDoubleAdjacencyListVertexInputFormat
extends TextDoubleDoubleAdjacencyListVertexInputFormat

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestTextDoubleDoubleAdjacencyListVertexInputFormat.DummyComputation

Nested classes/interfaces inherited from class org.apache.giraph.io.formats.TextDoubleDoubleAdjacencyListVertexInputFormat

TextDoubleDoubleAdjacencyListVertexInputFormat.TextDoubleDoubleAdjacencyListVertexReader

Nested classes/interfaces inherited from class org.apache.giraph.io.formats.AdjacencyListTextVertexInputFormat

AdjacencyListTextVertexInputFormat.AdjacencyListTextVertexReader, AdjacencyListTextVertexInputFormat.LineSanitizer

Nested classes/interfaces inherited from class org.apache.giraph.io.formats.TextVertexInputFormat

TextVertexInputFormat.TextVertexReader, TextVertexInputFormat.TextVertexReaderFromEachLine, TextVertexInputFormat.TextVertexReaderFromEachLineProcessed<T>, TextVertexInputFormat.TextVertexReaderFromEachLineProcessedHandlingExceptions<T,X extends Throwable>

Field Summary

Fields inherited from class org.apache.giraph.io.formats.AdjacencyListTextVertexInputFormat

LINE_TOKENIZE_VALUE, LINE_TOKENIZE_VALUE_DEFAULT

Fields inherited from class org.apache.giraph.io.formats.TextVertexInputFormat

textInputFormat

Constructor Summary

Constructors

Constructor and Description
TestTextDoubleDoubleAdjacencyListVertexInputFormat()

Method Summary

Modifier and Type	Method and Description
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.WritableComparable> void	assertValid(Vertex<I,V,E> expected, Vertex<I,V,E> actual)
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.WritableComparable> void	assertValidVertex(ImmutableClassesGiraphConfiguration<I,V,E> conf, Vertex<I,V,E> actual, I expectedId, V expectedValue, Edge<I,E>... edges)
protected TextVertexInputFormat.TextVertexReader	createVertexReader(org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text> rr)
protected TextVertexInputFormat.TextVertexReader	createVertexReader(org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text> rr, AdjacencyListTextVertexInputFormat.LineSanitizer lineSanitizer)
void	setUp()
void	testDifferentSeparators()
void	testEdgesMustHaveValues()
void	testHappyPath()
void	testIndexMustHaveValue()
void	testLineSanitizer()

Methods inherited from class org.apache.giraph.io.formats.TextDoubleDoubleAdjacencyListVertexInputFormat

createVertexReader

Methods inherited from class org.apache.giraph.io.formats.TextVertexInputFormat

checkInputSpecs, getSplits

Methods inherited from class org.apache.giraph.io.GiraphInputFormat

readInputSplit, writeInputSplit

Methods inherited from class org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable

getConf, setConf

Methods inherited from class java.lang.Object

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

Constructor Detail

TestTextDoubleDoubleAdjacencyListVertexInputFormat

public TestTextDoubleDoubleAdjacencyListVertexInputFormat()

Method Detail

setUp

public void setUp()
           throws IOException,
                  InterruptedException

Throws:

IOException

InterruptedException

createVertexReader

protected TextVertexInputFormat.TextVertexReader createVertexReader(org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text> rr)

createVertexReader

protected TextVertexInputFormat.TextVertexReader createVertexReader(org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text> rr,
                                                                    AdjacencyListTextVertexInputFormat.LineSanitizer lineSanitizer)

testIndexMustHaveValue

public void testIndexMustHaveValue()
                            throws IOException,
                                   InterruptedException

Throws:

IOException

InterruptedException

testEdgesMustHaveValues

public void testEdgesMustHaveValues()
                             throws IOException,
                                    InterruptedException

Throws:

IOException

InterruptedException

assertValidVertex

public static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.WritableComparable> void assertValidVertex(ImmutableClassesGiraphConfiguration<I,V,E> conf,
                                                                                                                                                                                   Vertex<I,V,E> actual,
                                                                                                                                                                                   I expectedId,
                                                                                                                                                                                   V expectedValue,
                                                                                                                                                                                   Edge<I,E>... edges)
                                                                                                                                                                            throws Exception

Throws:

Exception

assertValid

public static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.WritableComparable> void assertValid(Vertex<I,V,E> expected,
                                                                                                                                                                             Vertex<I,V,E> actual)

testHappyPath

public void testHappyPath()
                   throws Exception

Throws:

Exception

testLineSanitizer

public void testLineSanitizer()
                       throws Exception

Throws:

Exception

testDifferentSeparators

public void testDifferentSeparators()
                             throws Exception

Throws:

Exception