org.apache.giraph.io.gora

Class GoraGEdgeEdgeInputFormat.GoraGEdgeEdgeReader

java.lang.Object

org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable<I,V,E>

org.apache.giraph.worker.WorkerAggregatorDelegator<I,org.apache.hadoop.io.Writable,E>

org.apache.giraph.io.EdgeReader<I,E>

org.apache.giraph.io.gora.GoraEdgeInputFormat.GoraEdgeReader

org.apache.giraph.io.gora.GoraGEdgeEdgeInputFormat.GoraGEdgeEdgeReader

All Implemented Interfaces:

AggregatorUsage, 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>, WorkerAggregatorUsage, WorkerBroadcastUsage, WorkerGlobalCommUsage, WorkerReduceUsage

Enclosing class:

GoraGEdgeEdgeInputFormat

protected class GoraGEdgeEdgeInputFormat.GoraGEdgeEdgeReader
extends GoraEdgeInputFormat.GoraEdgeReader

Gora edge reader

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	GoraGEdgeEdgeReader()

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.io.LongWritable	getCurrentSourceId() Gets the currentSourceId for the edge.
protected Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable>	transformEdge(Object goraObject) Transforms a GoraObject into an Edge object.

Methods inherited from class org.apache.giraph.io.gora.GoraEdgeInputFormat.GoraEdgeReader

close, getCurrentEdge, getProgress, getResults, initialize, nextEdge

Methods inherited from class org.apache.giraph.worker.WorkerAggregatorDelegator

aggregate, getAggregatedValue, getBroadcast, reduce, reduceMerge, setWorkerGlobalCommUsage

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

GoraGEdgeEdgeReader

protected GoraGEdgeEdgeReader()

Method Detail

transformEdge

protected Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable> transformEdge(Object goraObject)

Transforms a GoraObject into an Edge object.

Specified by:

transformEdge in class GoraEdgeInputFormat.GoraEdgeReader

Parameters:

goraObject - Object from Gora to be translated.

Returns:

Edge Result from transforming the gora object.

getCurrentSourceId

public org.apache.hadoop.io.LongWritable getCurrentSourceId()
                                                     throws IOException,
                                                            InterruptedException

Gets the currentSourceId for the edge.

Specified by:

getCurrentSourceId in class EdgeReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable>

Returns:

LongWritable currentSourceId for the edge.

Throws:

IOException

InterruptedException