org.apache.giraph.io.formats

Class IntNullTextEdgeInputFormat

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

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>

Direct Known Subclasses:

IntNullReverseTextEdgeInputFormat

public class IntNullTextEdgeInputFormat
extends TextEdgeInputFormat<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.NullWritable>

Simple text-based EdgeInputFormat for unweighted graphs with int ids. Each line consists of: source_vertex, target_vertex

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	IntNullTextEdgeInputFormat.IntNullTextEdgeReader EdgeReader associated with IntNullTextEdgeInputFormat.

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
IntNullTextEdgeInputFormat()

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

IntNullTextEdgeInputFormat

public IntNullTextEdgeInputFormat()

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.

Specified by:

createEdgeReader in class EdgeInputFormat<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.NullWritable>

Parameters:

split - the split to be read

context - the information about the task

Returns:

a new record reader

Throws:

IOException