org.apache.giraph.examples

Class SimpleSuperstepComputation.SimpleSuperstepVertexReader

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.IntWritable,org.apache.hadoop.io.FloatWritable>

org.apache.giraph.examples.SimpleSuperstepComputation.SimpleSuperstepVertexReader

All Implemented Interfaces:

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

Enclosing class:

SimpleSuperstepComputation

public static class SimpleSuperstepComputation.SimpleSuperstepVertexReader
extends GeneratedVertexReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.FloatWritable>

Simple VertexReader that supports SimpleSuperstepComputation

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

Method Summary

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

SimpleSuperstepVertexReader

public SimpleSuperstepVertexReader()

Method Detail

nextVertex

public boolean nextVertex()
                   throws IOException,
                          InterruptedException

Specified by:

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

Returns:

false iff there are no more vertices

Throws:

IOException

InterruptedException

getCurrentVertex

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

Description copied from class: VertexReader

Get the current vertex.

Specified by:

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

Returns:

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

Throws:

IOException

InterruptedException