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 protectedTextVertexWriterToEachLine()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected abstract org.apache.hadoop.io.TextconvertVertexToLine(org.apache.giraph.graph.Vertex<I,V,E> vertex)Writes a line for the given vertex.voidwriteVertex(org.apache.giraph.graph.Vertex vertex)-
Methods inherited from class org.apache.giraph.io.formats.TextVertexOutputFormat.TextVertexWriter
close, createLineRecordWriter, getContext, getRecordWriter, initialize
-
-
-
-
Method Detail
-
writeVertex
public final void writeVertex(org.apache.giraph.graph.Vertex vertex) throws IOException, InterruptedException- Throws:
IOExceptionInterruptedException
-
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
-
-