org.apache.giraph.io

Class EdgeOutputFormat<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.EdgeOutputFormat<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, WrappedEdgeOutputFormat

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

abstract class which can only write edges

Constructor Summary

Constructors

Constructor and Description
EdgeOutputFormat()

Method Summary

Modifier and Type	Method and Description
abstract EdgeWriter<I,V,E>	createEdgeWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context) Create an edge 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

EdgeOutputFormat

public EdgeOutputFormat()

Method Detail

createEdgeWriter

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

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

Parameters:

context - the information about the task

Returns:

a new vertex writer

Throws:

IOException

InterruptedException