org.apache.giraph.io.gora

Class GoraGEdgeEdgeOutputFormat.GoraGEdgeEdgeWriter

java.lang.Object

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

org.apache.giraph.io.EdgeWriter<I,V,E>

org.apache.giraph.io.gora.GoraEdgeOutputFormat.GoraEdgeWriter

org.apache.giraph.io.gora.GoraGEdgeEdgeOutputFormat.GoraGEdgeEdgeWriter

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>

Enclosing class:

GoraGEdgeEdgeOutputFormat

protected class GoraGEdgeEdgeOutputFormat.GoraGEdgeEdgeWriter
extends GoraEdgeOutputFormat.GoraEdgeWriter

Gora edge writer.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	GoraGEdgeEdgeWriter()

Method Summary

Modifier and Type	Method and Description
protected org.apache.gora.persistency.Persistent	getGoraEdge(org.apache.hadoop.io.LongWritable srcId, org.apache.hadoop.io.DoubleWritable srcValue, Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable> edge) Each edge needs to be transformed into a Gora object to be sent to a specific data store.
protected Object	getGoraKey(org.apache.hadoop.io.LongWritable srcId, org.apache.hadoop.io.DoubleWritable srcValue, Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable> edge) Gets the correct key from a computed vertex.

Methods inherited from class org.apache.giraph.io.gora.GoraEdgeOutputFormat.GoraEdgeWriter

close, initialize, writeEdge

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

GoraGEdgeEdgeWriter

protected GoraGEdgeEdgeWriter()

Method Detail

getGoraEdge

protected org.apache.gora.persistency.Persistent getGoraEdge(org.apache.hadoop.io.LongWritable srcId,
                                                             org.apache.hadoop.io.DoubleWritable srcValue,
                                                             Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable> edge)

Description copied from class: GoraEdgeOutputFormat.GoraEdgeWriter

Each edge needs to be transformed into a Gora object to be sent to a specific data store.

Specified by:

getGoraEdge in class GoraEdgeOutputFormat.GoraEdgeWriter

Parameters:

srcId - source vertex id

srcValue - source vertex value

edge - edge to be transformed into a Gora object

Returns:

Gora representation of the vertex

getGoraKey

protected Object getGoraKey(org.apache.hadoop.io.LongWritable srcId,
                            org.apache.hadoop.io.DoubleWritable srcValue,
                            Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable> edge)

Description copied from class: GoraEdgeOutputFormat.GoraEdgeWriter

Gets the correct key from a computed vertex.

Specified by:

getGoraKey in class GoraEdgeOutputFormat.GoraEdgeWriter

Parameters:

srcId - source vertex id

srcValue - source vertex value

edge - edge to extract the key from.

Returns:

The key representing such edge.