org.apache.giraph.utils

Class ByteStructVertexIdIterator<I extends org.apache.hadoop.io.WritableComparable>

java.lang.Object

org.apache.giraph.utils.ByteStructVertexIdIterator<I>

Type Parameters:

I - Vertex id

All Implemented Interfaces:

VertexIdIterator<I>

Direct Known Subclasses:

ByteStructVertexIdDataIterator

public abstract class ByteStructVertexIdIterator<I extends org.apache.hadoop.io.WritableComparable>
extends Object
implements VertexIdIterator<I>

Common implementation for VertexIdEdgeIterator, VertexIdMessageIterator and VertexIdMessageBytesIterator.

Field Summary

Fields

Modifier and Type	Field and Description
protected ExtendedDataInput	extendedDataInput Reader of the serialized edges
protected I	vertexId Current vertex id

Constructor Summary

Constructors

Constructor and Description
ByteStructVertexIdIterator(ExtendedDataOutput extendedDataOutput, ImmutableClassesGiraphConfiguration<I,?,?> conf) Constructor.

Method Summary

Modifier and Type	Method and Description
I	getCurrentVertexId() Get the current vertex id.
boolean	hasNext() Returns true if the iteration has more elements.
I	releaseCurrentVertexId() The backing store of the current vertex id is now released.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.giraph.utils.VertexIdIterator

next

Field Detail

extendedDataInput

protected final ExtendedDataInput extendedDataInput

Reader of the serialized edges

vertexId

protected I extends org.apache.hadoop.io.WritableComparable vertexId

Current vertex id

Constructor Detail

ByteStructVertexIdIterator

public ByteStructVertexIdIterator(ExtendedDataOutput extendedDataOutput,
                                  ImmutableClassesGiraphConfiguration<I,?,?> conf)

Constructor.

Parameters:

extendedDataOutput - Extended data output

conf - Configuration

Method Detail

hasNext

public boolean hasNext()

Description copied from interface: VertexIdIterator

Returns true if the iteration has more elements.

Specified by:

hasNext in interface VertexIdIterator<I extends org.apache.hadoop.io.WritableComparable>

Returns:

True if the iteration has more elements.

getCurrentVertexId

public I getCurrentVertexId()

Description copied from interface: VertexIdIterator

Get the current vertex id. Ihis object's contents are only guaranteed until next() is called. To take ownership of this object call releaseCurrentVertexId() after getting a reference to this object.

Specified by:

getCurrentVertexId in interface VertexIdIterator<I extends org.apache.hadoop.io.WritableComparable>

Returns:

Current vertex id

releaseCurrentVertexId

public I releaseCurrentVertexId()

Description copied from interface: VertexIdIterator

The backing store of the current vertex id is now released. Further calls to getCurrentVertexId () without calling next() will return null.

Specified by:

releaseCurrentVertexId in interface VertexIdIterator<I extends org.apache.hadoop.io.WritableComparable>

Returns:

Current vertex id that was released