unipg.gila.io

Class PartitioningInputFormat

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<org.apache.hadoop.io.LongWritable,PartitioningVertexValue,EdgeValue>

unipg.gila.io.PartitioningInputFormat

All Implemented Interfaces:

org.apache.giraph.conf.GiraphConfigurationSettable<org.apache.hadoop.io.LongWritable,PartitioningVertexValue,EdgeValue>, org.apache.giraph.conf.ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.LongWritable,PartitioningVertexValue,EdgeValue>

public class PartitioningInputFormat
extends org.apache.giraph.io.formats.TextVertexInputFormat<org.apache.hadoop.io.LongWritable,PartitioningVertexValue,EdgeValue>

This class is the default input method for the partitioning algorithm. It accepts text files representing graphs in which each line represents a vertex and is structured as follows: [id, x coordinate, y coordinate, [[neighbor id] {, [neighbor id]}*]

Author:

Alessio Arleo

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	PartitioningInputFormat.PartitioningVertexReader

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

org.apache.giraph.io.formats.TextVertexInputFormat.TextVertexReader, org.apache.giraph.io.formats.TextVertexInputFormat.TextVertexReaderFromEachLine, org.apache.giraph.io.formats.TextVertexInputFormat.TextVertexReaderFromEachLineProcessed<T>, org.apache.giraph.io.formats.TextVertexInputFormat.TextVertexReaderFromEachLineProcessedHandlingExceptions<T,X extends java.lang.Throwable>

Field Summary

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

textInputFormat

Constructor Summary

Constructors

Constructor and Description
PartitioningInputFormat()

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.giraph.io.formats.TextVertexInputFormat.TextVertexReader	createVertexReader(org.apache.hadoop.mapreduce.InputSplit arg0, org.apache.hadoop.mapreduce.TaskAttemptContext arg1)

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

PartitioningInputFormat

public PartitioningInputFormat()

Method Detail

createVertexReader

public org.apache.giraph.io.formats.TextVertexInputFormat.TextVertexReader createVertexReader(org.apache.hadoop.mapreduce.InputSplit arg0,
                                                                                     org.apache.hadoop.mapreduce.TaskAttemptContext arg1)
                                                                                       throws java.io.IOException

Overrides:

createVertexReader in class org.apache.giraph.io.formats.TextVertexInputFormat<org.apache.hadoop.io.LongWritable,PartitioningVertexValue,EdgeValue>

Throws:

java.io.IOException