org.apache.giraph.io.formats

Class GraphvizOutputFormat

java.lang.Object

org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable<I,V,E>

org.apache.giraph.io.OutputFormat<I,V,E>

org.apache.giraph.io.VertexOutputFormat<I,V,E>

org.apache.giraph.io.formats.TextVertexOutputFormat<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>

org.apache.giraph.io.formats.GraphvizOutputFormat

All Implemented Interfaces:

GiraphConfigurationSettable<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>, ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>

public class GraphvizOutputFormat
extends TextVertexOutputFormat<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>

Writes graph to a dot file (graphviz format). This writes it out in parts. At the end of the job you can use the following to get a single graphviz file: hadoop fs -getmerge /hadoop/output/path data.txt

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.giraph.io.formats.TextVertexOutputFormat

TextVertexOutputFormat.TextVertexWriter, TextVertexOutputFormat.TextVertexWriterToEachLine

Field Summary

Fields inherited from class org.apache.giraph.io.formats.TextVertexOutputFormat

textOutputFormat

Constructor Summary

Constructors

Constructor and Description
GraphvizOutputFormat()

Method Summary

Modifier and Type	Method and Description
TextVertexOutputFormat.TextVertexWriter	createVertexWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context) The factory method which produces the TextVertexOutputFormat.TextVertexWriter used by this output format.
org.apache.hadoop.mapreduce.OutputCommitter	getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext context) Get the output committer for this output format.

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

checkOutputSpecs

Methods inherited from class org.apache.giraph.io.OutputFormat

postWriting, preWriting

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

GraphvizOutputFormat

public GraphvizOutputFormat()

Method Detail

createVertexWriter

public TextVertexOutputFormat.TextVertexWriter createVertexWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                           throws IOException,
                                                                  InterruptedException

Description copied from class: TextVertexOutputFormat

The factory method which produces the TextVertexOutputFormat.TextVertexWriter used by this output format.

Specified by:

createVertexWriter in class TextVertexOutputFormat<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>

Parameters:

context - the information about the task

Returns:

the text vertex writer to be used

Throws:

IOException

InterruptedException

getOutputCommitter

public org.apache.hadoop.mapreduce.OutputCommitter getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                               throws IOException,
                                                                      InterruptedException

Description copied from class: OutputFormat

Get the output committer for this output format. This is responsible for ensuring the output is committed correctly. (Copied from Hadoop OutputFormat)

Overrides:

getOutputCommitter in class TextVertexOutputFormat<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>

Parameters:

context - the task context

Returns:

an output committer

Throws:

IOException

InterruptedException