org.apache.giraph.io.gora

Class GoraTestEdgeOutputFormat.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.GoraTestEdgeOutputFormat.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:

GoraTestEdgeOutputFormat

protected class GoraTestEdgeOutputFormat.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)
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)
void	writeEdge(org.apache.hadoop.io.LongWritable srcId, org.apache.hadoop.io.DoubleWritable srcValue, Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable> edge)

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

close, initialize

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)

Specified by:

getGoraEdge in class GoraEdgeOutputFormat.GoraEdgeWriter

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)

Specified by:

getGoraKey in class GoraEdgeOutputFormat.GoraEdgeWriter

writeEdge

public void writeEdge(org.apache.hadoop.io.LongWritable srcId,
                      org.apache.hadoop.io.DoubleWritable srcValue,
                      Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable> edge)
               throws IOException,
                      InterruptedException

Overrides:

writeEdge in class GoraEdgeOutputFormat.GoraEdgeWriter

Throws:

IOException

InterruptedException