org.apache.giraph.io.formats

Class IntNullNullTextInputFormat.IntNullNullNullVertexReader

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,E>

org.apache.giraph.io.formats.TextVertexInputFormat.TextVertexReader

org.apache.giraph.io.formats.TextVertexInputFormat.TextVertexReaderFromEachLineProcessed<String>

org.apache.giraph.io.formats.IntNullNullTextInputFormat.IntNullNullNullVertexReader

All Implemented Interfaces:

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

Enclosing class:

IntNullNullTextInputFormat

public class IntNullNullTextInputFormat.IntNullNullNullVertexReader
extends TextVertexInputFormat.TextVertexReaderFromEachLineProcessed<String>

Reader for this InputFormat.

Constructor Summary

Constructors

Constructor and Description
IntNullNullNullVertexReader()

Method Summary

Modifier and Type	Method and Description
protected Iterable<Edge<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.NullWritable>>	getEdges(String line) Reads edges from the preprocessed line.
protected org.apache.hadoop.io.IntWritable	getId(String line) Reads vertex id from the preprocessed line.
protected org.apache.hadoop.io.NullWritable	getValue(String line) Reads vertex value from the preprocessed line.
protected String	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.TextVertexInputFormat.TextVertexReaderFromEachLineProcessed

getCurrentVertex, nextVertex

Methods inherited from class org.apache.giraph.io.formats.TextVertexInputFormat.TextVertexReader

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

IntNullNullNullVertexReader

public IntNullNullNullVertexReader()

Method Detail

preprocessLine

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

Description copied from class: TextVertexInputFormat.TextVertexReaderFromEachLineProcessed

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

Specified by:

preprocessLine in class TextVertexInputFormat.TextVertexReaderFromEachLineProcessed<String>

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(String line)
                                          throws IOException

Description copied from class: TextVertexInputFormat.TextVertexReaderFromEachLineProcessed

Reads vertex id from the preprocessed line.

Specified by:

getId in class TextVertexInputFormat.TextVertexReaderFromEachLineProcessed<String>

Parameters:

line - 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.NullWritable getValue(String line)
                                              throws IOException

Description copied from class: TextVertexInputFormat.TextVertexReaderFromEachLineProcessed

Reads vertex value from the preprocessed line.

Specified by:

getValue in class TextVertexInputFormat.TextVertexReaderFromEachLineProcessed<String>

Parameters:

line - the object obtained by preprocessing the line

Returns:

the vertex value

Throws:

IOException - exception that can be thrown while reading

getEdges

protected Iterable<Edge<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.NullWritable>> getEdges(String line)
                                                                                               throws IOException

Description copied from class: TextVertexInputFormat.TextVertexReaderFromEachLineProcessed

Reads edges from the preprocessed line.

Specified by:

getEdges in class TextVertexInputFormat.TextVertexReaderFromEachLineProcessed<String>

Parameters:

line - the object obtained by preprocessing the line

Returns:

the edges

Throws:

IOException - exception that can be thrown while reading