Package org.apache.wayang.giraph.Algorithm

Class PageRankAlgorithm.PageRankVertexReader

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.wayang.giraph.Algorithm.PageRankAlgorithm.PageRankVertexReader

All Implemented Interfaces:

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

Enclosing class:

PageRankAlgorithm

public static class PageRankAlgorithm.PageRankVertexReader
extends org.apache.giraph.examples.GeneratedVertexReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>

Simple VertexReader that supports PageRankAlgorithm

Field Summary

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

inputSplit, READER_VERTICES, recordsRead, REVERSE_ID_ORDER, reverseIdOrder, totalRecords

Constructor Summary

Constructors

Constructor	Description
PageRankVertexReader()

Method Summary

Modifier and Type	Method	Description
org.apache.giraph.graph.Vertex<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>	getCurrentVertex()
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

PageRankVertexReader

public PageRankVertexReader()

Method Detail

nextVertex

public boolean nextVertex()

Specified by:

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

getCurrentVertex

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

Specified by:

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

Throws:

java.io.IOException