org.apache.giraph.io.gora

Class GoraGVertexVertexInputFormat

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.gora.GoraVertexInputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>

org.apache.giraph.io.gora.GoraGVertexVertexInputFormat

All Implemented Interfaces:

GiraphConfigurationSettable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>, ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>

public class GoraGVertexVertexInputFormat
extends GoraVertexInputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>

Example implementation of a specific reader for a generated data bean.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	GoraGVertexVertexInputFormat.GoraGVertexVertexReader Gora vertex reader

Nested classes/interfaces inherited from class org.apache.giraph.io.gora.GoraVertexInputFormat

GoraVertexInputFormat.GoraVertexReader

Constructor Summary

Constructors

Constructor and Description
GoraGVertexVertexInputFormat() DEfault constructor

Method Summary

Modifier and Type	Method and Description
GoraVertexInputFormat.GoraVertexReader	createVertexReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) Creates specific vertex reader to be used inside Hadoop.

Methods inherited from class org.apache.giraph.io.gora.GoraVertexInputFormat

checkInputSpecs, createDataStore, getDataStore, getDatastoreClass, getSplits, getStartKey, setDataStore, setDatastoreClass, setStartKey

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

GoraGVertexVertexInputFormat

public GoraGVertexVertexInputFormat()

DEfault constructor

Method Detail

createVertexReader

public GoraVertexInputFormat.GoraVertexReader createVertexReader(org.apache.hadoop.mapreduce.InputSplit split,
                                                                 org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                          throws IOException

Creates specific vertex reader to be used inside Hadoop.

Specified by:

createVertexReader in class GoraVertexInputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>

Parameters:

split - split to be read.

context - JobContext to be used.

Returns:

GoraVertexReader Vertex reader to be used by Hadoop.

Throws:

IOException