org.apache.giraph.io.formats

Class SrcIdDstIdEdgeValueTextOutputFormat.SrcIdDstIdEdgeValueEdgeWriter<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>

org.apache.giraph.io.formats.SrcIdDstIdEdgeValueTextOutputFormat.SrcIdDstIdEdgeValueEdgeWriter<I,V,E>

All Implemented Interfaces:

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

Enclosing class:

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

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

Edge writer used with SrcIdDstIdEdgeValueTextOutputFormat.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SrcIdDstIdEdgeValueEdgeWriter()

Method Summary

Modifier and Type	Method and Description
protected org.apache.hadoop.io.Text	convertEdgeToLine(I sourceId, V sourceValue, Edge<I,E> edge) Writes a line for the given edge.
void	initialize(org.apache.hadoop.mapreduce.TaskAttemptContext context) Use the context to setup writing the edges.

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

writeEdge

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

close, createLineRecordWriter, getContext, getRecordWriter

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

SrcIdDstIdEdgeValueEdgeWriter

protected SrcIdDstIdEdgeValueEdgeWriter()

Method Detail

initialize

public void initialize(org.apache.hadoop.mapreduce.TaskAttemptContext context)
                throws IOException,
                       InterruptedException

Description copied from class: EdgeWriter

Use the context to setup writing the edges. Guaranteed to be called prior to any other function.

Overrides:

initialize in class TextEdgeOutputFormat.TextEdgeWriter<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

Parameters:

context - Context used to write the vertices.

Throws:

IOException

InterruptedException

convertEdgeToLine

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

Description copied from class: TextEdgeOutputFormat.TextEdgeWriterToEachLine

Writes a line for the given edge.

Specified by:

convertEdgeToLine in class TextEdgeOutputFormat.TextEdgeWriterToEachLine<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

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