edu.iu.dsc.tws.comms.shuffle

Interface Shuffle

All Known Implementing Classes:

FSKeyedMerger, FSKeyedSortedMerger, FSKeyedSortedMerger2, FSMerger

public interface Shuffle

Different interfaces to go to disk

Method Summary

Modifier and Type	Method and Description
default void	add(byte[] data, int length) Add object
default void	add(java.lang.Object key, byte[] data, int length) Add an object with a key
default void	add(Tuple tuple) Add tuple with byte value and key
default void	clean() Clean the file system
java.util.Iterator<java.lang.Object>	readIterator() Get a read iterator
default void	run() Execute the shuffle operation.
void	switchToReading() Switch to reading, we cannot add after this

Method Detail

switchToReading

void switchToReading()

Switch to reading, we cannot add after this

readIterator

java.util.Iterator<java.lang.Object> readIterator()

Get a read iterator

Returns:

an iterator

add

default void add(Tuple tuple)

Add tuple with byte value and key

Parameters:

tuple - tuple

add

default void add(java.lang.Object key,
                 byte[] data,
                 int length)

Add an object with a key

Parameters:

key - the object key

data - the data

length - length of the data

add

default void add(byte[] data,
                 int length)

Add object

Parameters:

data - the data as bytes

length - the length of data

run

default void run()

Execute the shuffle operation. This will save the content

clean

default void clean()

Clean the file system