org.apache.giraph.io.gora

Class GoraGEdgeEdgeOutputFormat

java.lang.Object

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

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

org.apache.giraph.io.gora.GoraEdgeOutputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>

org.apache.giraph.io.gora.GoraGEdgeEdgeOutputFormat

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 GoraGEdgeEdgeOutputFormat
extends GoraEdgeOutputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>

Implementation of a specific writer for a generated data bean.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	GoraGEdgeEdgeOutputFormat.GoraGEdgeEdgeWriter Gora edge writer.

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

GoraEdgeOutputFormat.GoraEdgeWriter

Constructor Summary

Constructors

Constructor and Description
GoraGEdgeEdgeOutputFormat() Default constructor

Method Summary

Modifier and Type	Method and Description
GoraEdgeOutputFormat.GoraEdgeWriter	createEdgeWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context) Create an edge writer for a given split.

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

checkOutputSpecs, createDataStore, getDataStore, getDatastoreClass, getLogger, getOutputCommitter, setDataStore, setDatastoreClass

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

GoraGEdgeEdgeOutputFormat

public GoraGEdgeEdgeOutputFormat()

Default constructor

Method Detail

createEdgeWriter

public GoraEdgeOutputFormat.GoraEdgeWriter createEdgeWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                     throws IOException,
                                                            InterruptedException

Description copied from class: EdgeOutputFormat

Create an edge writer for a given split. The framework will call EdgeWriter.initialize(TaskAttemptContext) before the split is used.

Specified by:

createEdgeWriter in class GoraEdgeOutputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>

Parameters:

context - the information about the task

Returns:

a new vertex writer

Throws:

IOException

InterruptedException