org.apache.giraph.utils

Class ByteStructVertexIdMessageBytesIterator<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>

java.lang.Object

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

org.apache.giraph.utils.ByteStructVertexIdDataIterator<I,M>

org.apache.giraph.utils.ByteStructVertexIdMessageBytesIterator<I,M>

Type Parameters:

I - vertexId type parameter

M - message type parameter

All Implemented Interfaces:

VertexIdDataIterator<I,M>, VertexIdIterator<I>, VertexIdMessageBytesIterator<I,M>

@NotThreadSafe
public abstract class ByteStructVertexIdMessageBytesIterator<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>
extends ByteStructVertexIdDataIterator<I,M>
implements VertexIdMessageBytesIterator<I,M>

Special iterator that reuses vertex ids and messages bytes so that the lifetime of the object is only until next() is called. Vertex id ownership can be released if desired through releaseCurrentVertexId(). This optimization allows us to cut down on the number of objects instantiated and garbage collected. Messages can only be copied to an ExtendedDataOutput object

Field Summary

Fields

Modifier and Type	Field and Description
protected int	messageBytes Number of bytes in the last message
protected int	messageOffset Last message offset

Fields inherited from class org.apache.giraph.utils.ByteStructVertexIdDataIterator

dataSize, vertexIdData

Fields inherited from class org.apache.giraph.utils.ByteStructVertexIdIterator

extendedDataInput, vertexId

Constructor Summary

Constructors

Constructor and Description
ByteStructVertexIdMessageBytesIterator(AbstractVertexIdData<I,M> vertexIdData) Constructor with vertexIdData

Method Summary

Modifier and Type	Method and Description
void	next() Moves to the next element in the iteration.

Methods inherited from class org.apache.giraph.utils.ByteStructVertexIdDataIterator

getCurrentData, getCurrentDataSize, releaseCurrentData

Methods inherited from class org.apache.giraph.utils.ByteStructVertexIdIterator

getCurrentVertexId, hasNext, releaseCurrentVertexId

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.VertexIdMessageBytesIterator

writeCurrentMessageBytes

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

getCurrentData, getCurrentDataSize, releaseCurrentData

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

getCurrentVertexId, hasNext, releaseCurrentVertexId

Field Detail

messageOffset

protected int messageOffset

Last message offset

messageBytes

protected int messageBytes

Number of bytes in the last message

Constructor Detail

ByteStructVertexIdMessageBytesIterator

public ByteStructVertexIdMessageBytesIterator(AbstractVertexIdData<I,M> vertexIdData)

Constructor with vertexIdData

Parameters:

vertexIdData - vertexIdData

Method Detail

next

public void next()

Moves to the next element in the iteration.

Specified by:

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

Overrides:

next in class ByteStructVertexIdDataIterator<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>