org.apache.giraph.io.formats

Class IntIntTextVertexValueInputFormat<E extends org.apache.hadoop.io.Writable>

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,org.apache.hadoop.io.Writable>

org.apache.giraph.io.VertexValueInputFormat<I,V>

org.apache.giraph.io.formats.TextVertexValueInputFormat<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.IntWritable,E>

org.apache.giraph.io.formats.IntIntTextVertexValueInputFormat<E>

Type Parameters:

E - Edge value

All Implemented Interfaces:

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

public class IntIntTextVertexValueInputFormat<E extends org.apache.hadoop.io.Writable>
extends TextVertexValueInputFormat<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.IntWritable,E>

Simple text-based VertexValueInputFormat for integer ids and values. Each line consists of: id, value

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	IntIntTextVertexValueInputFormat.IntIntTextVertexValueReader VertexValueReader associated with IntIntTextVertexValueInputFormat.

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

TextVertexValueInputFormat.TextVertexValueReader, TextVertexValueInputFormat.TextVertexValueReaderFromEachLine, TextVertexValueInputFormat.TextVertexValueReaderFromEachLineProcessed<T>

Field Summary

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

textInputFormat

Constructor Summary

Constructors

Constructor and Description
IntIntTextVertexValueInputFormat()

Method Summary

Modifier and Type	Method and Description
TextVertexValueInputFormat.TextVertexValueReader	createVertexValueReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) Create a VertexValueReader for a given split.

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

checkInputSpecs, getSplits

Methods inherited from class org.apache.giraph.io.VertexValueInputFormat

createVertexReader

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

IntIntTextVertexValueInputFormat

public IntIntTextVertexValueInputFormat()

Method Detail

createVertexValueReader

public TextVertexValueInputFormat.TextVertexValueReader createVertexValueReader(org.apache.hadoop.mapreduce.InputSplit split,
                                                                                org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                                         throws IOException

Description copied from class: VertexValueInputFormat

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

Specified by:

createVertexValueReader in class TextVertexValueInputFormat<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.IntWritable,E extends org.apache.hadoop.io.Writable>

Parameters:

split - The split to be read

context - The information about the task

Returns:

A new vertex value reader

Throws:

IOException