org.apache.reef.io.storage.ram

Class SortingRamSpool<T>

java.lang.Object

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

All Implemented Interfaces:

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

public class SortingRamSpool<T>
extends Object
implements Spool<T>

Constructor Summary

Constructors

Constructor and Description
SortingRamSpool()
SortingRamSpool(Comparator<T> c)

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

SortingRamSpool

public SortingRamSpool()

SortingRamSpool

public SortingRamSpool(Comparator<T> c)

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()
                           throws StorageException

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

Throws:

StorageException