org.apache.giraph.io.formats

Class TextEdgeOutputFormat.TextEdgeWriterToEachLine<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>

org.apache.giraph.io.formats.TextEdgeOutputFormat.TextEdgeWriter<I,V,E>

org.apache.giraph.io.formats.TextEdgeOutputFormat.TextEdgeWriterToEachLine<I,V,E>

All Implemented Interfaces:

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

Direct Known Subclasses:

SrcIdDstIdEdgeValueTextOutputFormat.SrcIdDstIdEdgeValueEdgeWriter

Enclosing class:

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

protected abstract class TextEdgeOutputFormat.TextEdgeWriterToEachLine<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
extends TextEdgeOutputFormat.TextEdgeWriter<I,V,E>

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

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TextEdgeWriterToEachLine()

Method Summary

Modifier and Type	Method and Description
protected abstract org.apache.hadoop.io.Text	convertEdgeToLine(I sourceId, V sourceValue, Edge<I,E> edge) Writes a line for the given edge.
void	writeEdge(I sourceId, V sourceValue, Edge<I,E> edge) Writes the next vertex and associated data

Methods inherited from class org.apache.giraph.io.formats.TextEdgeOutputFormat.TextEdgeWriter

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

TextEdgeWriterToEachLine

protected TextEdgeWriterToEachLine()

Method Detail

writeEdge

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

Description copied from class: EdgeWriter

Writes the next vertex and associated data

Specified by:

writeEdge in class EdgeWriter<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

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

convertEdgeToLine

protected abstract org.apache.hadoop.io.Text convertEdgeToLine(I sourceId,
                                                               V sourceValue,
                                                               Edge<I,E> edge)
                                                        throws IOException

Writes a line for the given edge.

Parameters:

sourceId - the current id of the source vertex

sourceValue - the current value of the source vertex

edge - the current vertex for writing

Returns:

the text line to be written

Throws:

IOException - exception that can be thrown while writing