public class TestLongDoubleDoubleAdjacencyListVertexInputFormat extends LongDoubleDoubleAdjacencyListVertexInputFormat
Modifier and Type | Class and Description |
---|---|
static class |
TestLongDoubleDoubleAdjacencyListVertexInputFormat.DummyComputation |
LongDoubleDoubleAdjacencyListVertexInputFormat.LongDoubleDoubleAdjacencyListVertexReader
AdjacencyListTextVertexInputFormat.AdjacencyListTextVertexReader, AdjacencyListTextVertexInputFormat.LineSanitizer
TextVertexInputFormat.TextVertexReader, TextVertexInputFormat.TextVertexReaderFromEachLine, TextVertexInputFormat.TextVertexReaderFromEachLineProcessed<T>, TextVertexInputFormat.TextVertexReaderFromEachLineProcessedHandlingExceptions<T,X extends Throwable>
LINE_TOKENIZE_VALUE, LINE_TOKENIZE_VALUE_DEFAULT
textInputFormat
Constructor and Description |
---|
TestLongDoubleDoubleAdjacencyListVertexInputFormat() |
Modifier and Type | Method and Description |
---|---|
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() |
createVertexReader
checkInputSpecs, getSplits
readInputSplit, writeInputSplit
getConf, setConf
public TestLongDoubleDoubleAdjacencyListVertexInputFormat()
public void setUp() throws IOException, InterruptedException
IOException
InterruptedException
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)
public void testIndexMustHaveValue() throws IOException, InterruptedException
IOException
InterruptedException
public void testEdgesMustHaveValues() throws IOException, InterruptedException
IOException
InterruptedException
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.