org.apache.giraph.utils

Class ByteStructVertexIdMessageIterator<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.ByteStructVertexIdMessageIterator<I,M>

Type Parameters:

I - vertexId type parameter

M - message type parameter

All Implemented Interfaces:

VertexIdDataIterator<I,M>, VertexIdIterator<I>, VertexIdMessageIterator<I,M>

public class ByteStructVertexIdMessageIterator<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>
extends ByteStructVertexIdDataIterator<I,M>
implements VertexIdMessageIterator<I,M>

Special iterator that reuses vertex ids and message objects so that the lifetime of the object is only until next() is called.

Field Summary

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
ByteStructVertexIdMessageIterator(AbstractVertexIdData<I,M> vertexIdData) Constructor with vertexIdData

Method Summary

Modifier and Type	Method and Description
M	getCurrentMessage() Get the current message.
int	getCurrentMessageSize() Get the serialized size of current message
boolean	isNewMessage() Return true of current message is new

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

getCurrentData, getCurrentDataSize, next, 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.VertexIdDataIterator

getCurrentData, getCurrentDataSize, releaseCurrentData

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

getCurrentVertexId, hasNext, next, releaseCurrentVertexId

Constructor Detail

ByteStructVertexIdMessageIterator

public ByteStructVertexIdMessageIterator(AbstractVertexIdData<I,M> vertexIdData)

Constructor with vertexIdData

Parameters:

vertexIdData - vertexIdData

Method Detail

getCurrentMessage

public M getCurrentMessage()

Description copied from interface: VertexIdMessageIterator

Get the current message.

Specified by:

getCurrentMessage in interface VertexIdMessageIterator<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>

Returns:

Current message

getCurrentMessageSize

public int getCurrentMessageSize()

Description copied from interface: VertexIdMessageIterator

Get the serialized size of current message

Specified by:

getCurrentMessageSize in interface VertexIdMessageIterator<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>

Returns:

serialized size of current message

isNewMessage

public boolean isNewMessage()

Description copied from interface: VertexIdMessageIterator

Return true of current message is new

Specified by:

isNewMessage in interface VertexIdMessageIterator<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>

Returns:

true if current message is new