public class IteratingSorter<T> extends SorterBase<T> implements Closeable
SortingState.Phase_cancelForException, _cancelRequest, _comparator, _config, _currentSortRound, _phase, _presortFileCount, _readerFactory, _sortRoundCount, _writerFactory| Constructor and Description |
|---|
IteratingSorter() |
IteratingSorter(SortConfig config) |
IteratingSorter(SortConfig config,
DataReaderFactory<T> readerFactory,
DataWriterFactory<T> writerFactory,
Comparator<T> comparator) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
Iterator<T> |
sort(DataReader<T> inputReader)
Method that will perform full sort on input data read using given
DataReader. |
_calculateRoundCount, _checkForCancel, _checkForCancel, _createMergeReader, _merge, _merge, _presort, _rawComparator, _readMax, _writeAll, _writePresorted, cancel, cancel, cancel, getNumberOfPreSortFiles, getNumberOfSortRounds, getPhase, getSortRound, isCompleted, isPreSorting, isSorting, merge, mergepublic IteratingSorter(SortConfig config, DataReaderFactory<T> readerFactory, DataWriterFactory<T> writerFactory, Comparator<T> comparator)
public IteratingSorter()
public IteratingSorter(SortConfig config)
public Iterator<T> sort(DataReader<T> inputReader) throws IOException
DataReader.
Conversions to and from intermediate sort files is done
using DataReaderFactory and DataWriterFactory configured
for this sorter.
The returned Iterator will throw IterableSorterException if any
IOException is encountered during calls of Iterator.next().IOExceptionpublic void close()
close in interface Closeableclose in interface AutoCloseableCopyright © 2022 FasterXML. All rights reserved.