org.apache.giraph.io

Class BasicVertexValueReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable>

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

org.apache.giraph.io.BasicVertexValueReader<I,V>

Type Parameters:

I - Vertex id

V - Vertex data

All Implemented Interfaces:

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

Direct Known Subclasses:

VertexValueReader

public abstract class BasicVertexValueReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable>
extends VertexReader<I,V,org.apache.hadoop.io.Writable>

Abstract base class for VertexValueReader.

Constructor Summary

Constructors

Constructor and Description
BasicVertexValueReader()

Method Summary

Modifier and Type	Method and Description
abstract I	getCurrentVertexId() User-defined method to extract the vertex id.
abstract V	getCurrentVertexValue() User-defined method to extract the vertex value.

Methods inherited from class org.apache.giraph.io.VertexReader

close, getCurrentVertex, getProgress, initialize, nextVertex

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

BasicVertexValueReader

public BasicVertexValueReader()

Method Detail

getCurrentVertexId

public abstract I getCurrentVertexId()
                              throws IOException,
                                     InterruptedException

User-defined method to extract the vertex id.

Returns:

The vertex id

Throws:

IOException

InterruptedException

getCurrentVertexValue

public abstract V getCurrentVertexValue()
                                 throws IOException,
                                        InterruptedException

User-defined method to extract the vertex value.

Returns:

The vertex value

Throws:

IOException

InterruptedException