org.apache.giraph.utils

Interface VertexIdMessageBytesIterator<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>

Type Parameters:

I - vertexId type parameter

M - message type parameter

All Superinterfaces:

VertexIdDataIterator<I,M>, VertexIdIterator<I>

All Known Implementing Classes:

ByteStructVertexIdMessageBytesIterator

public interface VertexIdMessageBytesIterator<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>
extends VertexIdDataIterator<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

Method Summary

Modifier and Type	Method and Description
void	writeCurrentMessageBytes(DataOutput dataOutput) Write the current message to an ExtendedDataOutput object

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

Method Detail

writeCurrentMessageBytes

void writeCurrentMessageBytes(DataOutput dataOutput)

Write the current message to an ExtendedDataOutput object

Parameters:

dataOutput - Where the current message will be written to