org.apache.giraph.comm.messages

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

java.lang.Object

org.apache.giraph.utils.ByteStructIterable<T>

org.apache.giraph.utils.RepresentativeByteStructIterable<M>

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

Type Parameters:

M - Message data

All Implemented Interfaces:

Iterable<M>

public class MessagesIterable<M extends org.apache.hadoop.io.Writable>
extends RepresentativeByteStructIterable<M>

Special iterable that recycles the message

Field Summary

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

dataInputFactory

Constructor Summary

Constructors

Constructor and Description
MessagesIterable(Factory<? extends ExtendedDataInput> dataInputFactory, MessageValueFactory<M> messageValueFactory) Constructor

Method Summary

Modifier and Type	Method and Description
protected M	createWritable() Must be able to create the writable object

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

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

MessagesIterable

public MessagesIterable(Factory<? extends ExtendedDataInput> dataInputFactory,
                        MessageValueFactory<M> messageValueFactory)

Constructor

Parameters:

dataInputFactory - Factory for data inputs

messageValueFactory - factory for creating message values

Method Detail

createWritable

protected M createWritable()

Description copied from class: ByteStructIterable

Must be able to create the writable object

Specified by:

createWritable in class ByteStructIterable<M extends org.apache.hadoop.io.Writable>

Returns:

New writable