public class TestSrcIdDstIdEdgeValueTextOutputFormat extends SrcIdDstIdEdgeValueTextOutputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>
Modifier and Type | Class and Description |
---|---|
static class |
TestSrcIdDstIdEdgeValueTextOutputFormat.DummyComputation
Dummy class to allow ImmutableClassesGiraphConfiguration to be created.
|
SrcIdDstIdEdgeValueTextOutputFormat.SrcIdDstIdEdgeValueEdgeWriter<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
TextEdgeOutputFormat.TextEdgeWriter<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>, TextEdgeOutputFormat.TextEdgeWriterToEachLine<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
textOutputFormat
Constructor and Description |
---|
TestSrcIdDstIdEdgeValueTextOutputFormat() |
Modifier and Type | Method and Description |
---|---|
void |
setUp() |
void |
testHappyPath() |
void |
testReverseIdAndValue() |
void |
testWithDifferentDelimiter() |
createEdgeWriter
checkOutputSpecs, getOutputCommitter
postWriting, preWriting
getConf, setConf
public TestSrcIdDstIdEdgeValueTextOutputFormat()
public void setUp()
public void testHappyPath() throws IOException, InterruptedException
IOException
InterruptedException
public void testReverseIdAndValue() throws IOException, InterruptedException
IOException
InterruptedException
public void testWithDifferentDelimiter() throws IOException, InterruptedException
IOException
InterruptedException
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.