org.apache.giraph.io.formats

Class IntNullTextEdgeInputFormat.IntNullTextEdgeReader

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.TextEdgeReaderFromEachLineProcessed<IntPair>

org.apache.giraph.io.formats.IntNullTextEdgeInputFormat.IntNullTextEdgeReader

All Implemented Interfaces:

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

Enclosing class:

IntNullTextEdgeInputFormat

public class IntNullTextEdgeInputFormat.IntNullTextEdgeReader
extends TextEdgeInputFormat.TextEdgeReaderFromEachLineProcessed<IntPair>

EdgeReader associated with IntNullTextEdgeInputFormat.

Constructor Summary

Constructors

Constructor and Description
IntNullTextEdgeReader()

Method Summary

Modifier and Type	Method and Description
protected org.apache.hadoop.io.IntWritable	getSourceVertexId(IntPair endpoints) Reads source vertex id from the preprocessed line.
protected org.apache.hadoop.io.IntWritable	getTargetVertexId(IntPair endpoints) Reads target vertex id from the preprocessed line.
protected org.apache.hadoop.io.NullWritable	getValue(IntPair endpoints) Reads edge value from the preprocessed line.
protected IntPair	preprocessLine(org.apache.hadoop.io.Text line) Preprocess the line so other methods can easily read necessary information for creating edge

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

getCurrentEdge, getCurrentSourceId, nextEdge

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

IntNullTextEdgeReader

public IntNullTextEdgeReader()

Method Detail

preprocessLine

protected IntPair preprocessLine(org.apache.hadoop.io.Text line)
                          throws IOException

Description copied from class: TextEdgeInputFormat.TextEdgeReaderFromEachLineProcessed

Preprocess the line so other methods can easily read necessary information for creating edge

Specified by:

preprocessLine in class TextEdgeInputFormat.TextEdgeReaderFromEachLineProcessed<IntPair>

Parameters:

line - the current line to be read

Returns:

the preprocessed object

Throws:

IOException - exception that can be thrown while reading

getSourceVertexId

protected org.apache.hadoop.io.IntWritable getSourceVertexId(IntPair endpoints)
                                                      throws IOException

Description copied from class: TextEdgeInputFormat.TextEdgeReaderFromEachLineProcessed

Reads source vertex id from the preprocessed line.

Specified by:

getSourceVertexId in class TextEdgeInputFormat.TextEdgeReaderFromEachLineProcessed<IntPair>

Parameters:

endpoints - the object obtained by preprocessing the line

Returns:

the source vertex id

Throws:

IOException - exception that can be thrown while reading

getTargetVertexId

protected org.apache.hadoop.io.IntWritable getTargetVertexId(IntPair endpoints)
                                                      throws IOException

Description copied from class: TextEdgeInputFormat.TextEdgeReaderFromEachLineProcessed

Reads target vertex id from the preprocessed line.

Specified by:

getTargetVertexId in class TextEdgeInputFormat.TextEdgeReaderFromEachLineProcessed<IntPair>

Parameters:

endpoints - the object obtained by preprocessing the line

Returns:

the target vertex id

Throws:

IOException - exception that can be thrown while reading

getValue

protected org.apache.hadoop.io.NullWritable getValue(IntPair endpoints)
                                              throws IOException

Description copied from class: TextEdgeInputFormat.TextEdgeReaderFromEachLineProcessed

Reads edge value from the preprocessed line.

Specified by:

getValue in class TextEdgeInputFormat.TextEdgeReaderFromEachLineProcessed<IntPair>

Parameters:

endpoints - the object obtained by preprocessing the line

Returns:

the edge value

Throws:

IOException - exception that can be thrown while reading