org.apache.giraph.io.gora

Class GoraGEdgeEdgeInputFormat

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

org.apache.giraph.io.gora.GoraGEdgeEdgeInputFormat

All Implemented Interfaces:

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

public class GoraGEdgeEdgeInputFormat
extends GoraEdgeInputFormat<org.apache.hadoop.io.LongWritable,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	GoraGEdgeEdgeInputFormat.GoraGEdgeEdgeReader Gora edge reader

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

GoraEdgeInputFormat.GoraEdgeReader

Constructor Summary

Constructors

Constructor and Description
GoraGEdgeEdgeInputFormat() Default constructor

Method Summary

Modifier and Type	Method and Description
GoraEdgeInputFormat.GoraEdgeReader	createEdgeReader(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.GoraEdgeInputFormat

checkInputSpecs, createDataStore, getDataStore, getDatastoreClass, getLogger, 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

GoraGEdgeEdgeInputFormat

public GoraGEdgeEdgeInputFormat()

Default constructor

Method Detail

createEdgeReader

public GoraEdgeInputFormat.GoraEdgeReader createEdgeReader(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:

createEdgeReader in class GoraEdgeInputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable>

Parameters:

split - split to be read.

context - JobContext to be used.

Returns:

GoraEdgeReader Edge reader to be used by Hadoop.

Throws:

IOException