org.apache.reef.io.storage.local

Class SerializerFileSpool<T>

java.lang.Object

org.apache.reef.io.storage.local.SerializerFileSpool<T>

Type Parameters:

T -

All Implemented Interfaces:

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

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

A SpoolFile backed by the filesystem.

Constructor Summary

Constructors

Constructor and Description
SerializerFileSpool(LocalStorageService service, Serializer<T,OutputStream> out, Deserializer<T,InputStream> in)

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

SerializerFileSpool

public SerializerFileSpool(LocalStorageService service,
                   Serializer<T,OutputStream> out,
                   Deserializer<T,InputStream> in)
                    throws ServiceException

Throws:

ServiceException

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