com.soteradefense.dga.io.formats

Class DGAAbstractEdgeOutputFormat.DGAAbstractEdgeWriter<I extends WritableComparable,V extends Writable,E extends 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>

com.soteradefense.dga.io.formats.DGAAbstractEdgeOutputFormat.DGAAbstractEdgeWriter<I,V,E>

All Implemented Interfaces:

ImmutableClassesGiraphConfigurable<I,V,E>

Direct Known Subclasses:

DGAEdgeTDTOutputFormat.TDTEdgeWriter, DGAEdgeTTTOutputFormat.TTTEdgeWriter

Enclosing class:

DGAAbstractEdgeOutputFormat<I extends WritableComparable,V extends Writable,E extends Writable>

protected abstract class DGAAbstractEdgeOutputFormat.DGAAbstractEdgeWriter<I extends WritableComparable,V extends Writable,E extends Writable>
extends TextEdgeOutputFormat.TextEdgeWriterToEachLine<I,V,E>

A Edge Writer that writes each edge into a file on HDFS.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DGAAbstractEdgeOutputFormat.DGAAbstractEdgeWriter()

Method Summary

Methods

Modifier and Type	Method and Description
protected Text	convertEdgeToLine(I sourceId, V vertexValue, Edge<I,E> edge)
abstract String	getEdgeValueAsString(E edgeValue) The implementing classes must convert their Writable object into a String that can be appended to the String of text that will become our Text output
abstract String	getVertexValueAsString(V vertexValue) The implementing classes must convert their Writable object into a String that can be appended to the String of text that will become our Text output
void	initialize(TaskAttemptContext context) Upon intialization, determines the field separator and default weight to use from the GiraphConfiguration

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

DGAAbstractEdgeOutputFormat.DGAAbstractEdgeWriter

protected DGAAbstractEdgeOutputFormat.DGAAbstractEdgeWriter()

Method Detail

initialize

public void initialize(TaskAttemptContext context)
                throws IOException,
                       InterruptedException

Upon intialization, determines the field separator and default weight to use from the GiraphConfiguration

Overrides:

initialize in class TextEdgeOutputFormat.TextEdgeWriter<I extends WritableComparable,V extends Writable,E extends Writable>

Parameters:

context -

Throws:

IOException

InterruptedException

getVertexValueAsString

public abstract String getVertexValueAsString(V vertexValue)

The implementing classes must convert their Writable object into a String that can be appended to the String of text that will become our Text output

Parameters:

vertexValue -

Returns:

getEdgeValueAsString

public abstract String getEdgeValueAsString(E edgeValue)

The implementing classes must convert their Writable object into a String that can be appended to the String of text that will become our Text output

Parameters:

edgeValue -

Returns:

convertEdgeToLine

protected Text convertEdgeToLine(I sourceId,
                     V vertexValue,
                     Edge<I,E> edge)
                          throws IOException

Specified by:

convertEdgeToLine in class TextEdgeOutputFormat.TextEdgeWriterToEachLine<I extends WritableComparable,V extends Writable,E extends Writable>

Throws:

IOException