public final class Sort extends Object
sort(File, File)
Modifier and Type | Class and Description |
---|---|
static class |
Sort.BufferSize
A bit more descriptive unit for constructors.
|
static class |
Sort.ByteSequencesReader
Utility class to read length-prefixed byte[] entries from an input.
|
static class |
Sort.ByteSequencesWriter
Utility class to emit length-prefixed byte[] entries to an output stream for sorting.
|
class |
Sort.SortInfo
Sort info (debugging mostly).
|
Modifier and Type | Field and Description |
---|---|
static long |
ABSOLUTE_MIN_SORT_BUFFER_SIZE
Absolute minimum required buffer size for sorting.
|
static Comparator<BytesRef> |
DEFAULT_COMPARATOR |
static long |
GB |
static int |
MAX_TEMPFILES
Maximum number of temporary files before doing an intermediate merge.
|
static long |
MB |
static long |
MIN_BUFFER_SIZE_MB
Minimum recommended buffer size for sorting.
|
Constructor and Description |
---|
Sort()
Defaults constructor.
|
Sort(Comparator<BytesRef> comparator) |
Sort(Comparator<BytesRef> comparator,
Sort.BufferSize ramBufferSize,
File tempDirectory,
int maxTempfiles)
All-details constructor.
|
Modifier and Type | Method and Description |
---|---|
static File |
defaultTempDir()
Returns the default temporary directory.
|
Comparator<BytesRef> |
getComparator() |
Sort.SortInfo |
sort(File input,
File output)
Sort input to output, explicit hint for the buffer size.
|
protected File |
sortPartition(int len)
Sort a single partition in-memory.
|
public static final long MB
public static final long GB
public static final long MIN_BUFFER_SIZE_MB
public static final long ABSOLUTE_MIN_SORT_BUFFER_SIZE
public static final int MAX_TEMPFILES
public static final Comparator<BytesRef> DEFAULT_COMPARATOR
public Sort() throws IOException
IOException
defaultTempDir()
,
Sort.BufferSize.automatic()
public Sort(Comparator<BytesRef> comparator) throws IOException
IOException
public Sort(Comparator<BytesRef> comparator, Sort.BufferSize ramBufferSize, File tempDirectory, int maxTempfiles)
public Sort.SortInfo sort(File input, File output) throws IOException
IOException
public static File defaultTempDir() throws IOException
IOException
protected File sortPartition(int len) throws IOException
IOException
public Comparator<BytesRef> getComparator()