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:

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

Direct Known Subclasses:

AdjacencyListTextVertexOutputFormat.AdjacencyListTextVertexWriter, IdWithValueTextOutputFormat.IdWithValueVertexWriter, JsonBase64VertexOutputFormat.JsonBase64VertexWriter

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 and Description
protected	TextVertexWriterToEachLine()

Method Summary

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

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(Vertex vertex)
                       throws IOException,
                              InterruptedException

Description copied from interface: SimpleVertexWriter

Writes the next vertex and associated data

Parameters:

vertex - set the properties of this vertex

Throws:

IOException

InterruptedException

convertVertexToLine

protected abstract org.apache.hadoop.io.Text convertVertexToLine(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