org.apache.giraph.io.formats

Class TextEdgeInputFormat.TextEdgeReaderFromEachLine

java.lang.Object

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

org.apache.giraph.worker.WorkerAggregatorDelegator<I,org.apache.hadoop.io.Writable,E>

org.apache.giraph.io.EdgeReader<I,E>

org.apache.giraph.io.formats.TextEdgeInputFormat.TextEdgeReader

org.apache.giraph.io.formats.TextEdgeInputFormat.TextEdgeReaderFromEachLine

All Implemented Interfaces:

AggregatorUsage, GiraphConfigurationSettable<I,org.apache.hadoop.io.Writable,E>, ImmutableClassesGiraphConfigurable<I,org.apache.hadoop.io.Writable,E>, WorkerAggregatorUsage, WorkerBroadcastUsage, WorkerGlobalCommUsage, WorkerReduceUsage

Enclosing class:

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

protected abstract class TextEdgeInputFormat.TextEdgeReaderFromEachLine
extends TextEdgeInputFormat.TextEdgeReader

Abstract class to be implemented by the user to read an edge from each text line.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TextEdgeReaderFromEachLine()

Method Summary

Modifier and Type	Method and Description
Edge<I,E>	getCurrentEdge() Get the current edge.
I	getCurrentSourceId() Get the current edge source id.
protected abstract I	getSourceVertexId(org.apache.hadoop.io.Text line) Reads source vertex id from the current line.
protected abstract I	getTargetVertexId(org.apache.hadoop.io.Text line) Reads target vertex id from the current line.
protected abstract E	getValue(org.apache.hadoop.io.Text line) Reads edge value from the current line.
boolean	nextEdge() Read the next edge.

Methods inherited from class org.apache.giraph.io.formats.TextEdgeInputFormat.TextEdgeReader

close, createLineRecordReader, getContext, getProgress, getRecordReader, initialize

Methods inherited from class org.apache.giraph.worker.WorkerAggregatorDelegator

aggregate, getAggregatedValue, getBroadcast, reduce, reduceMerge, setWorkerGlobalCommUsage

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

TextEdgeReaderFromEachLine

protected TextEdgeReaderFromEachLine()

Method Detail

getCurrentSourceId

public final I getCurrentSourceId()
                           throws IOException,
                                  InterruptedException

Description copied from class: EdgeReader

Get the current edge source id.

Specified by:

getCurrentSourceId in class EdgeReader<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>

Returns:

Current edge source id which has been read. nextEdge() should be called first.

Throws:

IOException

InterruptedException

getCurrentEdge

public final Edge<I,E> getCurrentEdge()
                               throws IOException,
                                      InterruptedException

Description copied from class: EdgeReader

Get the current edge.

Specified by:

getCurrentEdge in class EdgeReader<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>

Returns:

the current edge which has been read. nextEdge() should be called first.

Throws:

IOException

InterruptedException

nextEdge

public final boolean nextEdge()
                       throws IOException,
                              InterruptedException

Description copied from class: EdgeReader

Read the next edge.

Specified by:

nextEdge in class EdgeReader<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>

Returns:

false iff there are no more edges

Throws:

IOException

InterruptedException

getSourceVertexId

protected abstract I getSourceVertexId(org.apache.hadoop.io.Text line)
                                throws IOException

Reads source vertex id from the current line.

Parameters:

line - the current line

Returns:

the source vertex id corresponding to the line

Throws:

IOException - exception that can be thrown while reading

getTargetVertexId

protected abstract I getTargetVertexId(org.apache.hadoop.io.Text line)
                                throws IOException

Reads target vertex id from the current line.

Parameters:

line - the current line

Returns:

the target vertex id corresponding to the line

Throws:

IOException - exception that can be thrown while reading

getValue

protected abstract E getValue(org.apache.hadoop.io.Text line)
                       throws IOException

Reads edge value from the current line.

Parameters:

line - the current line

Returns:

the edge value corresponding to the line

Throws:

IOException - exception that can be thrown while reading