edu.iu.dsc.tws.comms.shuffle

Class ControlledMemoryReader

java.lang.Object

edu.iu.dsc.tws.comms.shuffle.ControlledMemoryReader

All Implemented Interfaces:

ControlledReader<Tuple>, Restorable, RestorableIterator<Tuple>, java.lang.Comparable<ControlledReader<Tuple>>, java.util.Iterator<Tuple>

public class ControlledMemoryReader
extends java.lang.Object
implements ControlledReader<Tuple>

Wrapper for tuples in memory.

Constructor Summary

Constructors

Constructor and Description
ControlledMemoryReader(java.util.List<Tuple> messages, java.util.Comparator keyComparator)

Method Summary

Modifier and Type	Method and Description
void	clearRestorePoint()
int	compareTo(ControlledReader<Tuple> o)
void	createRestorePoint()
boolean	hasNext()
boolean	hasRestorePoint()
Tuple	next()
java.lang.Object	nextKey() Get the next key
void	open() Open the reader
void	releaseResources() Release resources associated with this reader
void	restore()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Constructor Detail

ControlledMemoryReader

public ControlledMemoryReader(java.util.List<Tuple> messages,
                              java.util.Comparator keyComparator)

Method Detail

open

public void open()

Description copied from interface: ControlledReader

Open the reader

Specified by:

open in interface ControlledReader<Tuple>

releaseResources

public void releaseResources()

Description copied from interface: ControlledReader

Release resources associated with this reader

Specified by:

releaseResources in interface ControlledReader<Tuple>

hasNext

public boolean hasNext()

Specified by:

hasNext in interface java.util.Iterator<Tuple>

nextKey

public java.lang.Object nextKey()

Description copied from interface: ControlledReader

Get the next key

Specified by:

nextKey in interface ControlledReader<Tuple>

Returns:

return the next key

next

public Tuple next()

Specified by:

next in interface java.util.Iterator<Tuple>

createRestorePoint

public void createRestorePoint()

Specified by:

createRestorePoint in interface Restorable

restore

public void restore()

Specified by:

restore in interface Restorable

clearRestorePoint

public void clearRestorePoint()

Specified by:

clearRestorePoint in interface Restorable

hasRestorePoint

public boolean hasRestorePoint()

Specified by:

hasRestorePoint in interface Restorable

compareTo

public int compareTo(ControlledReader<Tuple> o)

Specified by:

compareTo in interface java.lang.Comparable<ControlledReader<Tuple>>