com.soteradefense.dga.io.formats

Class DGAEdgeTDTOutputFormat

java.lang.Object

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

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

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

com.soteradefense.dga.io.formats.DGAAbstractEdgeOutputFormat<Text,DoubleWritable,Text>

com.soteradefense.dga.io.formats.DGAEdgeTDTOutputFormat

All Implemented Interfaces:

ImmutableClassesGiraphConfigurable<Text,DoubleWritable,Text>

public class DGAEdgeTDTOutputFormat
extends DGAAbstractEdgeOutputFormat<Text,DoubleWritable,Text>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	DGAEdgeTDTOutputFormat.TDTEdgeWriter A Simple Edge Writer that writes each edge into a file on HDFS.

Nested classes/interfaces inherited from class com.soteradefense.dga.io.formats.DGAAbstractEdgeOutputFormat

DGAAbstractEdgeOutputFormat.DGAAbstractEdgeWriter<I extends WritableComparable,V extends Writable,E extends Writable>

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

TextEdgeOutputFormat.TextEdgeWriter<I extends WritableComparable,V extends Writable,E extends Writable>, TextEdgeOutputFormat.TextEdgeWriterToEachLine<I extends WritableComparable,V extends Writable,E extends Writable>

Field Summary

Fields inherited from class com.soteradefense.dga.io.formats.DGAAbstractEdgeOutputFormat

FIELD_DELIMITER, FIELD_DELIMITER_DEFAULT, WRITE_EDGE_VALUE, WRITE_EDGE_VALUE_DEFAULT, WRITE_VERTEX_VALUE, WRITE_VERTEX_VALUE_DEFAULT

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

textOutputFormat

Constructor Summary

Constructors

Constructor and Description
DGAEdgeTDTOutputFormat()

Method Summary

Methods

Modifier and Type	Method and Description
TextEdgeOutputFormat.TextEdgeWriter<Text,DoubleWritable,Text>	createEdgeWriter(TaskAttemptContext context)

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

checkOutputSpecs, getOutputCommitter

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

DGAEdgeTDTOutputFormat

public DGAEdgeTDTOutputFormat()

Method Detail

createEdgeWriter

public TextEdgeOutputFormat.TextEdgeWriter<Text,DoubleWritable,Text> createEdgeWriter(TaskAttemptContext context)
                                                                               throws IOException,
                                                                                      InterruptedException

Overrides:

createEdgeWriter in class TextEdgeOutputFormat<Text,DoubleWritable,Text>

Throws:

IOException

InterruptedException