org.apache.directory.mavibot.btree.memory

Class BulkDataSorter<K,V>

java.lang.Object

org.apache.directory.mavibot.btree.memory.BulkDataSorter<K,V>

public class BulkDataSorter<K,V>
extends java.lang.Object

A utility class for sorting a large number of keys before building a BTree using InMemoryBTreeBuilder.

Field Summary

Fields

Modifier and Type	Field and Description
private TupleReaderWriter<K,V>	readerWriter
private boolean	sorted
private int	splitAfter
private java.util.Comparator<Tuple<K,V>>	tupleComparator
private java.io.File	workDir

Constructor Summary

Constructors

Constructor and Description
BulkDataSorter(TupleReaderWriter<K,V> readerWriter, java.util.Comparator<Tuple<K,V>> tupleComparator, int splitAfter)

Method Summary

Modifier and Type	Method and Description
java.util.Iterator<Tuple<K,V>>	getMergeSortedTuples()
java.io.File	getWorkDir()
void	sort(java.io.File dataFile)
private void	storeSortedData(Tuple<K,V>[] arr)

Methods inherited from class java.lang.Object

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

Field Detail

workDir

private java.io.File workDir

splitAfter

private int splitAfter

tupleComparator

private java.util.Comparator<Tuple<K,V>> tupleComparator

readerWriter

private TupleReaderWriter<K,V> readerWriter

sorted

private boolean sorted

Constructor Detail

BulkDataSorter

public BulkDataSorter(TupleReaderWriter<K,V> readerWriter,
                      java.util.Comparator<Tuple<K,V>> tupleComparator,
                      int splitAfter)

Method Detail

sort

public void sort(java.io.File dataFile)
          throws java.io.IOException

Throws:

java.io.IOException

storeSortedData

private void storeSortedData(Tuple<K,V>[] arr)
                      throws java.io.IOException

Throws:

java.io.IOException

getWorkDir

public java.io.File getWorkDir()

getMergeSortedTuples

public java.util.Iterator<Tuple<K,V>> getMergeSortedTuples()
                                                    throws java.io.IOException

Throws:

java.io.IOException