org.apache.giraph.io

Class VertexOutputFormat<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

java.lang.Object

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

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

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

Type Parameters:

I - Vertex index value

V - Vertex value

E - Edge value

All Implemented Interfaces:

GiraphConfigurationSettable<I,V,E>, ImmutableClassesGiraphConfigurable<I,V,E>

Direct Known Subclasses:

InMemoryVertexOutputFormat, SequenceFileVertexOutputFormat, TextVertexOutputFormat, WrappedVertexOutputFormat

public abstract class VertexOutputFormat<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
extends OutputFormat<I,V,E>

Implement to output the graph after the computation. It is modeled directly after the Hadoop OutputFormat. ImmutableClassesGiraphConfiguration is available It's guaranteed that whatever parameters are set in the configuration are also going to be available in all method arguments related to this output format (context in createVertexWriter, checkOutputSpecs and getOutputCommitter; methods invoked on VertexWriter and OutputCommitter). So if backing output format relies on some parameters from configuration, you can safely set them for example in DefaultImmutableClassesGiraphConfigurable.setConf(org.apache.giraph.conf.ImmutableClassesGiraphConfiguration).

Constructor Summary

Constructors

Constructor and Description
VertexOutputFormat()

Method Summary

Modifier and Type	Method and Description
abstract VertexWriter<I,V,E>	createVertexWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context) Create a vertex writer for a given split.

Methods inherited from class org.apache.giraph.io.OutputFormat

checkOutputSpecs, getOutputCommitter, postWriting, preWriting

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

VertexOutputFormat

public VertexOutputFormat()

Method Detail

createVertexWriter

public abstract VertexWriter<I,V,E> createVertexWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                throws IOException,
                                                       InterruptedException

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

Parameters:

context - the information about the task

Returns:

a new vertex writer

Throws:

IOException

InterruptedException