com.soteradefense.dga.io.formats

Class DGATextEdgeValueInputFormat

java.lang.Object

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

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

org.apache.giraph.io.EdgeInputFormat<I,E>

org.apache.giraph.io.formats.TextEdgeInputFormat<Text,E>

com.soteradefense.dga.io.formats.DGAAbstractEdgeInputFormat<Text>

com.soteradefense.dga.io.formats.DGATextEdgeValueInputFormat

All Implemented Interfaces:

ImmutableClassesGiraphConfigurable<Text,Writable,Text>

public class DGATextEdgeValueInputFormat
extends DGAAbstractEdgeInputFormat<Text>

Implementation of the DGAAbstractEdgeInputFormat for Text as the edgeValue Does no verification of the edgeValue and simply returns the third value as a Text

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	DGATextEdgeValueInputFormat.DGATextEdgeValueReader

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

DGAAbstractEdgeInputFormat.DGAAbstractEdgeReader<E extends Writable>

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

TextEdgeInputFormat.TextEdgeReader, TextEdgeInputFormat.TextEdgeReaderFromEachLine, TextEdgeInputFormat.TextEdgeReaderFromEachLineProcessed<T>

Field Summary

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

EDGE_VALUE, IO_EDGE_REVERSE_DUPLICATOR, IO_EDGE_REVERSE_DUPLICATOR_DEFAULT, LINE_TOKENIZE_VALUE, LINE_TOKENIZE_VALUE_DEFAULT

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

textInputFormat

Constructor Summary

Constructors

Constructor and Description
DGATextEdgeValueInputFormat()

Method Summary

Methods

Modifier and Type	Method and Description
EdgeReader<Text,Text>	createEdgeReader(InputSplit split, TaskAttemptContext context) The create edge reader first determines if we should reverse each edge; some data sets are undirected graphs and need the input format to reverse their connected nature.

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

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

DGATextEdgeValueInputFormat

public DGATextEdgeValueInputFormat()

Method Detail

createEdgeReader

public EdgeReader<Text,Text> createEdgeReader(InputSplit split,
                                     TaskAttemptContext context)
                                       throws IOException

The create edge reader first determines if we should reverse each edge; some data sets are undirected graphs and need the input format to reverse their connected nature. Calls the abstract method getEdgeReader() which will give us the appropriate EdgeReader for the subclass.

Specified by:

createEdgeReader in class EdgeInputFormat<Text,Text>

Parameters:

split -

context -

Returns:

Throws:

IOException