protected class IdWithValueTextOutputFormat.IdWithValueVertexWriter extends TextVertexOutputFormat.TextVertexWriterToEachLine
IdWithValueTextOutputFormat
.Modifier | Constructor and Description |
---|---|
protected |
IdWithValueVertexWriter() |
Modifier and Type | Method and Description |
---|---|
protected 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.
|
writeVertex
close, createLineRecordWriter, getContext, getRecordWriter
getConf, setConf
public void initialize(org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException, InterruptedException
VertexWriter
initialize
in class TextVertexOutputFormat.TextVertexWriter
context
- Context used to write the vertices.IOException
InterruptedException
protected org.apache.hadoop.io.Text convertVertexToLine(Vertex<I,V,E> vertex) throws IOException
TextVertexOutputFormat.TextVertexWriterToEachLine
convertVertexToLine
in class TextVertexOutputFormat.TextVertexWriterToEachLine
vertex
- the current vertex for writingIOException
- exception that can be thrown while writingCopyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.