org.apache.giraph.utils

Class ByteStructIterable<T extends org.apache.hadoop.io.Writable>

java.lang.Object

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

Type Parameters:

T - Type that extends Writable that will be iterated

All Implemented Interfaces:

Iterable<T>

Direct Known Subclasses:

RepresentativeByteStructIterable

public abstract class ByteStructIterable<T extends org.apache.hadoop.io.Writable>
extends Object
implements Iterable<T>

This iterable is designed to deserialize a byte array on the fly to provide new copies of writable objects when desired. It does not reuse objects, and instead creates a new one for every next().

Field Summary

Fields

Modifier and Type	Field and Description
protected Factory<? extends ExtendedDataInput>	dataInputFactory Factory for data input

Constructor Summary

Constructors

Constructor and Description
ByteStructIterable(Factory<? extends ExtendedDataInput> dataInputFactory) Constructor

Method Summary

Modifier and Type	Method and Description
protected abstract T	createWritable() Must be able to create the writable object
Iterator<T>	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

Field Detail

dataInputFactory

protected final Factory<? extends ExtendedDataInput> dataInputFactory

Factory for data input

Constructor Detail

ByteStructIterable

public ByteStructIterable(Factory<? extends ExtendedDataInput> dataInputFactory)

Constructor

Parameters:

dataInputFactory - Factory for data inputs

Method Detail

createWritable

protected abstract T createWritable()

Must be able to create the writable object

Returns:

New writable

iterator

public Iterator<T> iterator()

Specified by:

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