org.apache.reef.wake.storage

Class SequentialFileReader

java.lang.Object

org.apache.reef.wake.storage.SequentialFileReader

All Implemented Interfaces:

AutoCloseable, EStage<ReadRequest>, EventHandler<ReadRequest>, Stage

public class SequentialFileReader
extends Object
implements EStage<ReadRequest>

Constructor Summary

Constructors

Constructor and Description
SequentialFileReader()

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	onNext(ReadRequest value) Handles an event

Methods inherited from class java.lang.Object

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

Constructor Detail

SequentialFileReader

public SequentialFileReader()

Method Detail

onNext

public void onNext(ReadRequest value)

Description copied from interface: EventHandler

Handles an event

Specified by:

onNext in interface EventHandler<ReadRequest>

Parameters:

value - an event

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception