org.apache.giraph.comm.messages

Class PointerListMessagesIterable<M extends org.apache.hadoop.io.Writable>

java.lang.Object

org.apache.giraph.comm.messages.PointerListMessagesIterable<M>

Type Parameters:

M - messageType

All Implemented Interfaces:

Iterable<M>

public class PointerListMessagesIterable<M extends org.apache.hadoop.io.Writable>
extends Object
implements Iterable<M>

Create an iterable for messages based on a pointer list

Constructor Summary

Constructors

Constructor and Description
PointerListMessagesIterable(MessageValueFactory<M> messageValueFactory, it.unimi.dsi.fastutil.longs.LongArrayList pointers, ExtendedByteArrayOutputBuffer msgBuffer)

Method Summary

Modifier and Type	Method and Description
protected M	createMessage() Create message from factory
Iterator<M>	iterator()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

PointerListMessagesIterable

public PointerListMessagesIterable(MessageValueFactory<M> messageValueFactory,
                                   it.unimi.dsi.fastutil.longs.LongArrayList pointers,
                                   ExtendedByteArrayOutputBuffer msgBuffer)

Parameters:

messageValueFactory - message value factory

pointers - pointers to messages in buffer

msgBuffer - holds the byte arrays of serialized messages

Method Detail

createMessage

protected M createMessage()

Create message from factory

Returns:

message instance

iterator

public Iterator<M> iterator()

Specified by:

iterator in interface Iterable<M extends org.apache.hadoop.io.Writable>