com.soteradefense.dga.io.formats

Class LouvainVertexInputFormat

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<Text,LouvainNodeState,LongWritable>

com.soteradefense.dga.io.formats.LouvainVertexInputFormat

All Implemented Interfaces:

ImmutableClassesGiraphConfigurable<Text,LouvainNodeState,LongWritable>

public class LouvainVertexInputFormat
extends TextVertexInputFormat<Text,LouvainNodeState,LongWritable>

Reads in a graph from text file in hdfs. Required format in is a tab delimited file with 3 columns: idinternal weightedge list the edge list is a comma separated list of edges of the form id:weight The graph must be bi-directional i.e. if vertex 1 has edge 2:9, the vertex 2 must have id 1:9 This condition is not verified as the input is read, but results of the algorithm will not be correct, and the run may fail with exceptions.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	LouvainVertexInputFormat.LouvainVertexReader

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.TextVertexInputFormat

textInputFormat

Constructor Summary

Constructors

Constructor and Description
LouvainVertexInputFormat()

Method Summary

Methods

Modifier and Type	Method and Description
TextVertexInputFormat.TextVertexReader	createVertexReader(InputSplit inputSplit, TaskAttemptContext taskAttemptContext)

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

LouvainVertexInputFormat

public LouvainVertexInputFormat()

Method Detail

createVertexReader

public TextVertexInputFormat.TextVertexReader createVertexReader(InputSplit inputSplit,
                                                        TaskAttemptContext taskAttemptContext)
                                                          throws IOException

Overrides:

createVertexReader in class TextVertexInputFormat<Text,LouvainNodeState,LongWritable>

Throws:

IOException