org.apache.giraph.io.formats

Class IntIntTextVertexValueInputFormat.IntIntTextVertexValueReader

java.lang.Object

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

org.apache.giraph.worker.WorkerAggregatorDelegator<I,V,E>

org.apache.giraph.io.VertexReader<I,V,org.apache.hadoop.io.Writable>

org.apache.giraph.io.BasicVertexValueReader<I,V>

org.apache.giraph.io.VertexValueReader<I,V>

org.apache.giraph.io.formats.TextVertexValueInputFormat.TextVertexValueReader

org.apache.giraph.io.formats.TextVertexValueInputFormat.TextVertexValueReaderFromEachLineProcessed<IntPair>

org.apache.giraph.io.formats.IntIntTextVertexValueInputFormat.IntIntTextVertexValueReader

All Implemented Interfaces:

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

Enclosing class:

IntIntTextVertexValueInputFormat<E extends org.apache.hadoop.io.Writable>

public class IntIntTextVertexValueInputFormat.IntIntTextVertexValueReader
extends TextVertexValueInputFormat.TextVertexValueReaderFromEachLineProcessed<IntPair>

VertexValueReader associated with IntIntTextVertexValueInputFormat.

Constructor Summary

Constructors

Constructor and Description
IntIntTextVertexValueReader()

Method Summary

Modifier and Type	Method and Description
protected org.apache.hadoop.io.IntWritable	getId(IntPair data) Reads vertex id from the preprocessed line.
protected org.apache.hadoop.io.IntWritable	getValue(IntPair data) Reads vertex 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 vertex.

Methods inherited from class org.apache.giraph.io.formats.TextVertexValueInputFormat.TextVertexValueReaderFromEachLineProcessed

getCurrentVertexId, getCurrentVertexValue, nextVertex

Methods inherited from class org.apache.giraph.io.formats.TextVertexValueInputFormat.TextVertexValueReader

close, createLineRecordReader, getContext, getProgress, getRecordReader, initialize

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

getCurrentVertex

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

IntIntTextVertexValueReader

public IntIntTextVertexValueReader()

Method Detail

preprocessLine

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

Description copied from class: TextVertexValueInputFormat.TextVertexValueReaderFromEachLineProcessed

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

Specified by:

preprocessLine in class TextVertexValueInputFormat.TextVertexValueReaderFromEachLineProcessed<IntPair>

Parameters:

line - the current line to be read

Returns:

the preprocessed object

Throws:

IOException - exception that can be thrown while reading

getId

protected org.apache.hadoop.io.IntWritable getId(IntPair data)
                                          throws IOException

Description copied from class: TextVertexValueInputFormat.TextVertexValueReaderFromEachLineProcessed

Reads vertex id from the preprocessed line.

Specified by:

getId in class TextVertexValueInputFormat.TextVertexValueReaderFromEachLineProcessed<IntPair>

Parameters:

data - the object obtained by preprocessing the line

Returns:

the vertex id

Throws:

IOException - exception that can be thrown while reading

getValue

protected org.apache.hadoop.io.IntWritable getValue(IntPair data)
                                             throws IOException

Description copied from class: TextVertexValueInputFormat.TextVertexValueReaderFromEachLineProcessed

Reads vertex value from the preprocessed line.

Specified by:

getValue in class TextVertexValueInputFormat.TextVertexValueReaderFromEachLineProcessed<IntPair>

Parameters:

data - the object obtained by preprocessing the line

Returns:

the vertex value

Throws:

IOException - exception that can be thrown while reading