org.apache.giraph.io.formats

Class IntNullReverseTextEdgeInputFormat

java.lang.Object

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

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

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

org.apache.giraph.io.formats.TextEdgeInputFormat<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.NullWritable>

org.apache.giraph.io.formats.IntNullTextEdgeInputFormat

org.apache.giraph.io.formats.IntNullReverseTextEdgeInputFormat

All Implemented Interfaces:

GiraphConfigurationSettable<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.NullWritable>, ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.NullWritable>

public class IntNullReverseTextEdgeInputFormat
extends IntNullTextEdgeInputFormat

Simple text-based EdgeInputFormat for unweighted graphs with int ids. Each line consists of: source_vertex, target_vertex This version also creates the reverse edges.

Nested Class Summary

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

IntNullTextEdgeInputFormat.IntNullTextEdgeReader

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 org.apache.giraph.io.formats.TextEdgeInputFormat

textInputFormat

Constructor Summary

Constructors

Constructor and Description
IntNullReverseTextEdgeInputFormat()

Method Summary

Modifier and Type	Method and Description
EdgeReader<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.NullWritable>	createEdgeReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) Create an edge reader for a given split.

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

IntNullReverseTextEdgeInputFormat

public IntNullReverseTextEdgeInputFormat()

Method Detail

createEdgeReader

public EdgeReader<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.NullWritable> createEdgeReader(org.apache.hadoop.mapreduce.InputSplit split,
                                                                                                       org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                                                                throws IOException

Description copied from class: EdgeInputFormat

Create an edge reader for a given split. The framework will call EdgeReader.initialize(InputSplit, TaskAttemptContext) before the split is used.

Overrides:

createEdgeReader in class IntNullTextEdgeInputFormat

Parameters:

split - the split to be read

context - the information about the task

Returns:

a new record reader

Throws:

IOException