org.apache.giraph.io

Class VertexWriter<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.VertexWriter<I,V,E>

Type Parameters:

I - Vertex id

V - Vertex value

E - Edge value

All Implemented Interfaces:

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

Direct Known Subclasses:

TextVertexOutputFormat.TextVertexWriter

public abstract class VertexWriter<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
extends DefaultImmutableClassesGiraphConfigurable<I,V,E>
implements SimpleVertexWriter<I,V,E>

Implement to output a vertex range of the graph after the computation

Constructor Summary

Constructors

Constructor and Description
VertexWriter()

Method Summary

Modifier and Type	Method and Description
abstract void	close(org.apache.hadoop.mapreduce.TaskAttemptContext context) Close this VertexWriter to future operations.
abstract void	initialize(org.apache.hadoop.mapreduce.TaskAttemptContext context) Use the context to setup writing the vertices.

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

Methods inherited from interface org.apache.giraph.io.SimpleVertexWriter

writeVertex

Constructor Detail

VertexWriter

public VertexWriter()

Method Detail

initialize

public abstract void initialize(org.apache.hadoop.mapreduce.TaskAttemptContext context)
                         throws IOException,
                                InterruptedException

Use the context to setup writing the vertices. Guaranteed to be called prior to any other function.

Parameters:

context - Context used to write the vertices.

Throws:

IOException

InterruptedException

close

public abstract void close(org.apache.hadoop.mapreduce.TaskAttemptContext context)
                    throws IOException,
                           InterruptedException

Close this VertexWriter to future operations.

Parameters:

context - the context of the task

Throws:

IOException

InterruptedException