Package org.apache.jackrabbit.oak.commons.sort

Class ExternalSortByteArray

java.lang.Object

org.apache.jackrabbit.oak.commons.sort.ExternalSortByteArray

public class ExternalSortByteArray
extends Object

Variation of ExternalSort that stores the lines read from intermediate files as byte arrays to avoid the conversion from byte[] to String and then back.

Constructor Summary

Constructors

Constructor	Description
ExternalSortByteArray()

Method Summary

Modifier and Type	Method	Description
static <T> void	mergeSortedFilesBinary(List<Path> files, OutputStream fbw, Comparator<T> cmp, boolean distinct, Compression algorithm, Function<T,byte[]> typeToByteArray, Function<byte[],T> byteArrayToType)
static <T> void	mergeSortedFilesBinary(List<Path> files, OutputStream fbw, Comparator<T> cmp, boolean distinct, Compression algorithm, Function<T,byte[]> typeToByteArray, Function<byte[],T> byteArrayToType, int readBufferSize)

Methods inherited from class java.lang.Object

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

Constructor Detail

ExternalSortByteArray

public ExternalSortByteArray()

Method Detail

mergeSortedFilesBinary

public static <T> void mergeSortedFilesBinary(List<Path> files,
                                              OutputStream fbw,
                                              Comparator<T> cmp,
                                              boolean distinct,
                                              Compression algorithm,
                                              Function<T,byte[]> typeToByteArray,
                                              Function<byte[],T> byteArrayToType)
                                       throws IOException

Throws:

IOException

mergeSortedFilesBinary

public static <T> void mergeSortedFilesBinary(List<Path> files,
                                              OutputStream fbw,
                                              Comparator<T> cmp,
                                              boolean distinct,
                                              Compression algorithm,
                                              Function<T,byte[]> typeToByteArray,
                                              Function<byte[],T> byteArrayToType,
                                              int readBufferSize)
                                       throws IOException

Throws:

IOException