org.apache.giraph.io.gora

Class GoraTestVertexInputFormat

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

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 GoraTestVertexInputFormat
extends GoraVertexInputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,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	GoraTestVertexInputFormat.GoraGVertexVertexReader Gora vertex reader

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

GoraVertexInputFormat.GoraVertexReader

Constructor Summary

Constructors

Constructor and Description
GoraTestVertexInputFormat() DEfault constructor

Method Summary

Modifier and Type	Method and Description
static GVertex	createVertex(String id, Map<String,String> edges) Creates a vertex using an id and a set of edges.
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

GoraTestVertexInputFormat

public GoraTestVertexInputFormat()

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.

Overrides:

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

createVertex

public static GVertex createVertex(String id,
                                   Map<String,String> edges)

Creates a vertex using an id and a set of edges.

Parameters:

id - Vertex id.

edges - Set of edges.

Returns:

GVertex created.