org.apache.giraph.io

Class VertexValueInputFormat<I extends org.apache.hadoop.io.WritableComparable,V 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>

Type Parameters:

I - Vertex id

V - Vertex value

All Implemented Interfaces:

GiraphConfigurationSettable<I,V,org.apache.hadoop.io.Writable>, ImmutableClassesGiraphConfigurable<I,V,org.apache.hadoop.io.Writable>

Direct Known Subclasses:

TextVertexValueInputFormat

public abstract class VertexValueInputFormat<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable>
extends VertexInputFormat<I,V,org.apache.hadoop.io.Writable>

Vertex input format that only allows setting vertex id and value. It can be used in conjunction with EdgeInputFormat.

Constructor Summary

Constructors

Constructor and Description
VertexValueInputFormat()

Method Summary

Modifier and Type	Method and Description
VertexReader<I,V,org.apache.hadoop.io.Writable>	createVertexReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) Create a vertex reader for a given split.
abstract VertexValueReader<I,V>	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.GiraphInputFormat

checkInputSpecs, getSplits, 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

VertexValueInputFormat

public VertexValueInputFormat()

Method Detail

createVertexValueReader

public abstract VertexValueReader<I,V> createVertexValueReader(org.apache.hadoop.mapreduce.InputSplit split,
                                                               org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                        throws IOException

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

Parameters:

split - The split to be read

context - The information about the task

Returns:

A new vertex value reader

Throws:

IOException

createVertexReader

public final VertexReader<I,V,org.apache.hadoop.io.Writable> createVertexReader(org.apache.hadoop.mapreduce.InputSplit split,
                                                                                org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                                         throws IOException

Description copied from class: VertexInputFormat

Create a vertex reader for a given split. Guaranteed to have been configured with setConf() prior to use. The framework will also call VertexReader.initialize(InputSplit, TaskAttemptContext) before the split is used.

Specified by:

createVertexReader in class VertexInputFormat<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>

Parameters:

split - the split to be read

context - the information about the task

Returns:

a new record reader

Throws:

IOException