Package org.apache.giraph.io.formats

Class TextVertexOutputFormat.TextVertexWriterToEachLine

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

All Implemented Interfaces:

org.apache.giraph.conf.GiraphConfigurationSettable<I,V,E>, org.apache.giraph.conf.ImmutableClassesGiraphConfigurable<I,V,E>, org.apache.giraph.io.SimpleVertexWriter<I,V,E>

Enclosing class:

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

protected abstract class TextVertexOutputFormat.TextVertexWriterToEachLine
extends TextVertexOutputFormat.TextVertexWriter

Abstract class to be implemented by the user to write a line for each vertex.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TextVertexWriterToEachLine()

Method Summary

Modifier and Type	Method	Description
protected abstract org.apache.hadoop.io.Text	convertVertexToLine(org.apache.giraph.graph.Vertex<I,V,E> vertex)	Writes a line for the given vertex.
void	writeVertex(org.apache.giraph.graph.Vertex vertex)

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

close, createLineRecordWriter, getContext, getRecordWriter, initialize

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

TextVertexWriterToEachLine

protected TextVertexWriterToEachLine()

Method Detail

writeVertex

public final void writeVertex(org.apache.giraph.graph.Vertex vertex)
                       throws IOException,
                              InterruptedException

Throws:

IOException

InterruptedException

convertVertexToLine

protected abstract org.apache.hadoop.io.Text convertVertexToLine(org.apache.giraph.graph.Vertex<I,V,E> vertex)
                                                          throws IOException

Writes a line for the given vertex.

Parameters:

vertex - the current vertex for writing

Returns:

the text line to be written

Throws:

IOException - exception that can be thrown while writing