org.apache.giraph.io.gora

Class GoraGVertexVertexOutputFormat

java.lang.Object

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

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

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

org.apache.giraph.io.gora.GoraGVertexVertexOutputFormat

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 GoraGVertexVertexOutputFormat
extends GoraVertexOutputFormat<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	GoraGVertexVertexOutputFormat.GoraGVertexVertexWriter Gora vertex writer.

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

GoraVertexOutputFormat.GoraVertexWriter

Constructor Summary

Constructors

Constructor and Description
GoraGVertexVertexOutputFormat() DEfault constructor

Method Summary

Modifier and Type	Method and Description
VertexWriter<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>	createVertexWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context) Create a vertex writer for a given split.

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

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

GoraGVertexVertexOutputFormat

public GoraGVertexVertexOutputFormat()

DEfault constructor

Method Detail

createVertexWriter

public VertexWriter<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable> createVertexWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                                                                                                          throws IOException,
                                                                                                                                                 InterruptedException

Description copied from class: VertexOutputFormat

Create a vertex writer for a given split. The framework will call VertexWriter.initialize(TaskAttemptContext) before the split is used.

Specified by:

createVertexWriter in class VertexOutputFormat<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