org.apache.giraph.io

Class EdgeWriter<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.EdgeWriter<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>

Direct Known Subclasses:

TextEdgeOutputFormat.TextEdgeWriter

public abstract class EdgeWriter<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>

Constructor Summary

Constructors

Constructor and Description
EdgeWriter()

Method Summary

Modifier and Type	Method and Description
abstract void	close(org.apache.hadoop.mapreduce.TaskAttemptContext context) Close this EdgeWriter to future operations.
abstract void	initialize(org.apache.hadoop.mapreduce.TaskAttemptContext context) Use the context to setup writing the edges.
abstract void	writeEdge(I sourceId, V sourceValue, Edge<I,E> edge) Writes the next vertex and associated data

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

EdgeWriter

public EdgeWriter()

Method Detail

writeEdge

public abstract void writeEdge(I sourceId,
                               V sourceValue,
                               Edge<I,E> edge)
                        throws IOException,
                               InterruptedException

Writes the next vertex and associated data

Parameters:

sourceId - the vertex ID from which the edge originates

sourceValue - the vertex value; the vertex is the one from which the edge originates

edge - edge to be written

Throws:

IOException

InterruptedException

initialize

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

Use the context to setup writing the edges. 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 EdgeWriter to future operations.

Parameters:

context - the context of the task

Throws:

IOException

InterruptedException