org.apache.giraph.examples

Class PageRankWithKryoSimpleWritable.PageRankWithKryoVertexReader

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,PageRankWithKryoSimpleWritable.VertexValue,PageRankWithKryoSimpleWritable.EdgeValue>

org.apache.giraph.examples.PageRankWithKryoSimpleWritable.PageRankWithKryoVertexReader

All Implemented Interfaces:

AggregatorUsage, GiraphConfigurationSettable<org.apache.hadoop.io.LongWritable,PageRankWithKryoSimpleWritable.VertexValue,PageRankWithKryoSimpleWritable.EdgeValue>, ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.LongWritable,PageRankWithKryoSimpleWritable.VertexValue,PageRankWithKryoSimpleWritable.EdgeValue>, WorkerAggregatorUsage, WorkerBroadcastUsage, WorkerGlobalCommUsage, WorkerReduceUsage

Enclosing class:

PageRankWithKryoSimpleWritable

public static class PageRankWithKryoSimpleWritable.PageRankWithKryoVertexReader
extends GeneratedVertexReader<org.apache.hadoop.io.LongWritable,PageRankWithKryoSimpleWritable.VertexValue,PageRankWithKryoSimpleWritable.EdgeValue>

Simple VertexReader that supports PageRankWithKryoSimpleWritable

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
PageRankWithKryoVertexReader()

Method Summary

Modifier and Type	Method and Description
Vertex<org.apache.hadoop.io.LongWritable,PageRankWithKryoSimpleWritable.VertexValue,PageRankWithKryoSimpleWritable.EdgeValue>	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

PageRankWithKryoVertexReader

public PageRankWithKryoVertexReader()

Method Detail

nextVertex

public boolean nextVertex()

Specified by:

nextVertex in class VertexReader<org.apache.hadoop.io.LongWritable,PageRankWithKryoSimpleWritable.VertexValue,PageRankWithKryoSimpleWritable.EdgeValue>

Returns:

false iff there are no more vertices

getCurrentVertex

public Vertex<org.apache.hadoop.io.LongWritable,PageRankWithKryoSimpleWritable.VertexValue,PageRankWithKryoSimpleWritable.EdgeValue> getCurrentVertex()
                                                                                                                                               throws IOException

Description copied from class: VertexReader

Get the current vertex.

Specified by:

getCurrentVertex in class VertexReader<org.apache.hadoop.io.LongWritable,PageRankWithKryoSimpleWritable.VertexValue,PageRankWithKryoSimpleWritable.EdgeValue>

Returns:

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

Throws:

IOException