org.apache.reef.io.storage.local

Class CodecFileAccumulable<T,C extends Codec<T>>

java.lang.Object

org.apache.reef.io.storage.local.CodecFileAccumulable<T,C>

All Implemented Interfaces:

Accumulable<T>

public final class CodecFileAccumulable<T,C extends Codec<T>>
extends Object
implements Accumulable<T>

Constructor Summary

Constructors

Constructor and Description
CodecFileAccumulable(LocalStorageService s, C codec)

Method Summary

Methods

Modifier and Type	Method and Description
Accumulator<T>	accumulator() Returns a new Accumulator.
String	getName()

Methods inherited from class java.lang.Object

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

Constructor Detail

CodecFileAccumulable

public CodecFileAccumulable(LocalStorageService s,
                    C codec)

Method Detail

getName

public String getName()

accumulator

public Accumulator<T> accumulator()
                           throws StorageException

Description copied from interface: Accumulable

Returns a new Accumulator.

Specified by:

accumulator in interface Accumulable<T>

Returns:

the new Accumulator

Throws:

StorageException