org.apache.giraph.io.formats

Class AdjacencyListTextVertexOutputFormat.AdjacencyListTextVertexWriter

java.lang.Object

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

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

org.apache.giraph.io.formats.TextVertexOutputFormat.TextVertexWriter

org.apache.giraph.io.formats.TextVertexOutputFormat.TextVertexWriterToEachLine

org.apache.giraph.io.formats.AdjacencyListTextVertexOutputFormat.AdjacencyListTextVertexWriter

All Implemented Interfaces:

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

Enclosing class:

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

protected class AdjacencyListTextVertexOutputFormat.AdjacencyListTextVertexWriter
extends TextVertexOutputFormat.TextVertexWriterToEachLine

Vertex writer associated with AdjacencyListTextVertexOutputFormat.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AdjacencyListTextVertexWriter()

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.io.Text	convertVertexToLine(Vertex<I,V,E> vertex) Writes a line for the given vertex.
void	initialize(org.apache.hadoop.mapreduce.TaskAttemptContext context) Use the context to setup writing the vertices.

Methods inherited from class org.apache.giraph.io.formats.TextVertexOutputFormat.TextVertexWriterToEachLine

writeVertex

Methods inherited from class org.apache.giraph.io.formats.TextVertexOutputFormat.TextVertexWriter

close, createLineRecordWriter, getContext, getRecordWriter

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

AdjacencyListTextVertexWriter

protected AdjacencyListTextVertexWriter()

Method Detail

initialize

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

Description copied from class: VertexWriter

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

Overrides:

initialize in class TextVertexOutputFormat.TextVertexWriter

Parameters:

context - Context used to write the vertices.

Throws:

IOException

InterruptedException

convertVertexToLine

public org.apache.hadoop.io.Text convertVertexToLine(Vertex<I,V,E> vertex)
                                              throws IOException

Description copied from class: TextVertexOutputFormat.TextVertexWriterToEachLine

Writes a line for the given vertex.

Specified by:

convertVertexToLine in class TextVertexOutputFormat.TextVertexWriterToEachLine

Parameters:

vertex - the current vertex for writing

Returns:

the text line to be written

Throws:

IOException - exception that can be thrown while writing