org.apache.reef.io.storage.ram

Class RamSpool<T>

java.lang.Object

org.apache.reef.io.storage.ram.RamSpool<T>

All Implemented Interfaces:

Iterable<T>, Accumulable<T>, Spool<T>

public final class RamSpool<T>
extends Object
implements Spool<T>

A SpoolFile implementation that is backed by RAM.

It uses an ArrayList to store the objects in.

Constructor Summary

Constructors

Constructor and Description
RamSpool(RamStorageService ramStore)

Method Summary

Methods

Modifier and Type	Method and Description
Accumulator<T>	accumulator() Returns an Accumulator for the spool file.
Iterator<T>	iterator() Returns an Iterable over the spool file.

Methods inherited from class java.lang.Object

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

Constructor Detail

RamSpool

@Inject
public RamSpool(RamStorageService ramStore)

Method Detail

iterator

public Iterator<T> iterator()

Description copied from interface: Spool

Returns an Iterable over the spool file.

Depending on the implementation, this method may be called only once per Spool instance, or it may be called repeatedly. Similarly, with some Spool implementations, attempts to append to the SpoolFile after calling iterator() may fail fast with a ConcurrentModificationException.

Specified by:

iterator in interface Iterable<T>

Specified by:

iterator in interface Spool<T>

Returns:

An Iterator over the SpoolFile, in the order data was inserted.

accumulator

public Accumulator<T> accumulator()

Description copied from interface: Spool

Returns an Accumulator for the spool file.

Depending on the implementation, this method may be called only once per Spool instance, or it may be called repeatedly. Similarly, with some Spool implementations, attempts to append to the SpoolFile after calling iterator() may fail fast with a ConcurrentModificationException.

Specified by:

accumulator in interface Accumulable<T>

Specified by:

accumulator in interface Spool<T>

Returns:

the new Accumulator