org.apache.giraph.io.gora

Class GoraTestEdgeInputFormat

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.GoraTestEdgeInputFormat

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

Implementation of a specific reader for a generated data bean.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	GoraTestEdgeInputFormat.GoraGEdgeEdgeReader Gora edge reader

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

GoraEdgeInputFormat.GoraEdgeReader

Constructor Summary

Constructors

Constructor and Description
GoraTestEdgeInputFormat() 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

GoraTestEdgeInputFormat

public GoraTestEdgeInputFormat()

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.

Overrides:

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