org.apache.giraph.examples

Class SimplePageRankComputation.SimplePageRankVertexReader

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.examples.GeneratedVertexReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>

org.apache.giraph.examples.SimplePageRankComputation.SimplePageRankVertexReader

All Implemented Interfaces:

AggregatorUsage, GiraphConfigurationSettable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>, ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>, WorkerAggregatorUsage, WorkerBroadcastUsage, WorkerGlobalCommUsage, WorkerReduceUsage

Enclosing class:

SimplePageRankComputation

public static class SimplePageRankComputation.SimplePageRankVertexReader
extends GeneratedVertexReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>

Simple VertexReader that supports SimplePageRankComputation

Field Summary

Fields inherited from class org.apache.giraph.examples.GeneratedVertexReader

inputSplit, READER_VERTICES, recordsRead, REVERSE_ID_ORDER, reverseIdOrder, totalRecords

Constructor Summary

Constructors

Constructor and Description
SimplePageRankVertexReader()

Method Summary

Modifier and Type	Method and Description
Vertex<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>	getCurrentVertex() Get the current vertex.
boolean	nextVertex()

Methods inherited from class org.apache.giraph.examples.GeneratedVertexReader

close, getProgress, 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

SimplePageRankVertexReader

public SimplePageRankVertexReader()

Method Detail

nextVertex

public boolean nextVertex()

Specified by:

nextVertex in class VertexReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>

Returns:

false iff there are no more vertices

getCurrentVertex

public Vertex<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable> getCurrentVertex()
                                                                                                                                  throws IOException

Description copied from class: VertexReader

Get the current vertex.

Specified by:

getCurrentVertex in class VertexReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>

Returns:

the current vertex which has been read. nextVertex() should be called first.

Throws:

IOException