import com.fasterxml.sort.SortConfig; //导入依赖的package包/类
public SortedPathIterator(final Iterator<Path> iter) throws IOException {
  SortConfig config = new SortConfig().withMaxMemoryUsage(1000000);
  Sorter sorter = new TextFileSorter(config);

  DataReader<byte[]> reader = new DataReader<byte[]>() {
    @Override
    public byte[] readNext() throws IOException {
      if (!iter.hasNext()) {
        return null;
      }
      return iter.next().toString().getBytes(Charsets.UTF_8);
    }
    @Override
    public void close() throws IOException {}
    @Override
    public int estimateSizeInBytes(byte[] item) { return item.length; }
  };

  this.sortedIter = sorter.sort(reader);
}
 

import com.fasterxml.sort.SortConfig; //导入依赖的package包/类
public void sortFile(File in, File out, Comparator<String> cmp) {
	try {
		long availMem = Runtime.getRuntime().maxMemory()
				- (2048 * 1024 * 1024);
		long maxMem = (availMem >> 1);
		if (maxMem > MAX_HEAP_FOR_PRESORT) {
			maxMem = MAX_HEAP_FOR_PRESORT;
		} else if (maxMem < MIN_HEAP_FOR_PRESORT) {
			maxMem = MIN_HEAP_FOR_PRESORT;
		}
		final TextFileSorter sorter = new TextFileSorter(
				new SortConfig().withMaxMemoryUsage(maxMem));
		sorter.sort(new FileInputStream(in), new PrintStream(out));
	} catch (IOException e) {
		e.printStackTrace();
	}

}
 

import com.fasterxml.sort.SortConfig; //导入依赖的package包/类
public void sortFile(File in, File out) {
	try {
		long availMem = Runtime.getRuntime().maxMemory()
				- (40 * 1024 * 1024);
		long maxMem = (availMem >> 1);
		if (maxMem > MAX_HEAP_FOR_PRESORT) {
			maxMem = MAX_HEAP_FOR_PRESORT;
		} else if (maxMem < MIN_HEAP_FOR_PRESORT) {
			maxMem = MIN_HEAP_FOR_PRESORT;
		}
		final TextFileSorter sorter = new TextFileSorter(
				new SortConfig().withMaxMemoryUsage(maxMem));
		sorter.sort(new FileInputStream(in), new PrintStream(out));
	} catch (IOException e) {
		e.printStackTrace();
	}
}
 

import com.fasterxml.sort.SortConfig; //导入依赖的package包/类
public CsvFileSorter(Class<T> entryType, SortConfig config, CsvMapper mapper, CsvSchema schema, Comparator<T> comparator)
    throws IOException
{
    super(config, new ReaderFactory<T>(mapper.readerFor(mapper.constructType(entryType)), mapper, schema),
            new WriterFactory<T>(mapper, schema),
            comparator);
}
 

import com.fasterxml.sort.SortConfig; //导入依赖的package包/类
public TextFileShuffler() {
  this(new SortConfig());
}
 

import com.fasterxml.sort.SortConfig; //导入依赖的package包/类
private SortConfig getSortConfig (MergeTempFileProvider tmpFileProvider) {
    long maxMemory = Long.parseLong(context.getServiceManager().getConfigurationService().getProperty("fdbsql.sort.memory"));
    return new SortConfig().withTempFileProvider(tmpFileProvider).withMaxMemoryUsage(maxMemory);
}
 

import com.fasterxml.sort.SortConfig; //导入依赖的package包/类
private Sorter<IdAndVersion> createSorter(IdAndVersionFactory idAndVersionFactory) {
    SortConfig sortConfig = new SortConfig().withMaxMemoryUsage(DEFAULT_SORT_MEM);
    DataReaderFactory<IdAndVersion> dataReaderFactory = new IdAndVersionDataReaderFactory(idAndVersionFactory);
    DataWriterFactory<IdAndVersion> dataWriterFactory = new IdAndVersionDataWriterFactory();
    return new Sorter<IdAndVersion>(sortConfig, dataReaderFactory, dataWriterFactory, new NaturalComparator<IdAndVersion>());
}
 

import com.fasterxml.sort.SortConfig; //导入依赖的package包/类
public SplitFileSorter() {
    this(new SortConfig());
}