edu.iu.dsc.tws.comms.shuffle

Class FSSorter

java.lang.Object

edu.iu.dsc.tws.comms.shuffle.FSSorter

public class FSSorter
extends java.lang.Object

File based sorter of records, we assume we can read maxbytes from all the files in the disk into memory, this may not be the case for larger records and we have to take special consideration into that.

Constructor Summary

Constructors

Constructor and Description
FSSorter(int numOfFiles, java.lang.String dir, java.util.Comparator<java.lang.Object> comparator, int oBytes, java.util.List<Tuple> openValues, MessageType keyType, MessageType dataType)

Method Summary

Modifier and Type	Method and Description
java.lang.Object	next()

Methods inherited from class java.lang.Object

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

Constructor Detail

FSSorter

public FSSorter(int numOfFiles,
                java.lang.String dir,
                java.util.Comparator<java.lang.Object> comparator,
                int oBytes,
                java.util.List<Tuple> openValues,
                MessageType keyType,
                MessageType dataType)

Method Detail

next

public java.lang.Object next()