org.apache.giraph.examples

Class AggregatorsTestComputation.SimpleEdgeReader

java.lang.Object

org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable<I,V,E>

org.apache.giraph.worker.WorkerAggregatorDelegator<I,org.apache.hadoop.io.Writable,E>

org.apache.giraph.io.EdgeReader<I,E>

org.apache.giraph.examples.GeneratedEdgeReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable>

org.apache.giraph.examples.AggregatorsTestComputation.SimpleEdgeReader

All Implemented Interfaces:

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

Enclosing class:

AggregatorsTestComputation

public static class AggregatorsTestComputation.SimpleEdgeReader
extends GeneratedEdgeReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable>

Simple Edge Reader

Field Summary

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

DEFAULT_READER_EDGES, inputSplit, recordsRead, totalRecords

Constructor Summary

Constructors

Constructor and Description
SimpleEdgeReader()

Method Summary

Modifier and Type	Method and Description
Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable>	getCurrentEdge() Get the current edge.
org.apache.hadoop.io.LongWritable	getCurrentSourceId() Get the current edge source id.
boolean	nextEdge() Read the next edge.

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

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

SimpleEdgeReader

public SimpleEdgeReader()

Method Detail

nextEdge

public boolean nextEdge()

Description copied from class: EdgeReader

Read the next edge.

Specified by:

nextEdge in class EdgeReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable>

Returns:

false iff there are no more edges

getCurrentEdge

public Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable> getCurrentEdge()
                                                                                          throws IOException

Description copied from class: EdgeReader

Get the current edge.

Specified by:

getCurrentEdge in class EdgeReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable>

Returns:

the current edge which has been read. nextEdge() should be called first.

Throws:

IOException

getCurrentSourceId

public org.apache.hadoop.io.LongWritable getCurrentSourceId()
                                                     throws IOException,
                                                            InterruptedException

Description copied from class: EdgeReader

Get the current edge source id.

Specified by:

getCurrentSourceId in class EdgeReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.FloatWritable>

Returns:

Current edge source id which has been read. nextEdge() should be called first.

Throws:

IOException

InterruptedException