Restore previous APIs for compatibility

Author: nathanlws

src/main/java/com/fasterxml/sort/IteratingSorter.java

@@ -91,7 +91,7 @@ public Iterator<T> sort(DataReader<T> inputReader)
                     return null;
                 }
                 _mergerInputs = presorted;
-                _merger = merge(presorted);
+                _merger = _createMergeReader(merge(presorted));
                 iterator = new MergerIterator<T>(_merger);
             }
         } finally {

src/main/java/com/fasterxml/sort/Sorter.java

@@ -38,6 +38,18 @@ protected Sorter(SortConfig config) {
         super(config);
     }
 
+    protected Sorter<T> withReaderFactory(DataReaderFactory<T> f) {
+        return new Sorter<T>(_config, f, _writerFactory, _comparator);
+    }
+
+    protected Sorter<T> withWriterFactory(DataWriterFactory<T> f) {
+        return new Sorter<T>(_config, _readerFactory, f, _comparator);
+    }
+
+    protected Sorter<T> withComparator(Comparator<T> cmp) {
+        return new Sorter<T>(_config, _readerFactory, _writerFactory, cmp);
+    }
+
 
     /*
     /********************************************************************** 

src/main/java/com/fasterxml/sort/SorterBase.java

@@ -241,10 +241,21 @@ protected File _writePresorted(Object[] items) throws IOException
      */
 
     /**
-     * Main-level merge method called during once during sorting.
-     * @return DataReader that will produced a fully sorted stream.
+     * Main-level merge method that sorts the given input and writes to final output.
      */
-    protected DataReader<T> merge(List<File> presorted)
+    protected void merge(List<File> presorted, DataWriter<T> resultWriter)
+        throws IOException
+    {
+        List<File> inputs = merge(presorted);
+        // and then last around to produce the result file
+        _merge(inputs, resultWriter);
+    }
+
+    /**
+     * Main-level merge method that sorts the given input.
+     * @return List of files that are individually sorted and ready for final merge.
+     */
+    protected List<File> merge(List<File> presorted)
         throws IOException
     {
         // Ok, let's see how many rounds we should have...
@@ -264,7 +275,18 @@ protected DataReader<T> merge(List<File> presorted)
             // and then switch result files to be input files
             inputs = outputs;
         }
-        return _createMergeReader(inputs);
+        return inputs;
+    }
+
+    protected void _writeAll(DataWriter<T> resultWriter, Object[] items)
+        throws IOException
+    {
+        // need to go through acrobatics, due to type erasure... works, if ugly:
+        @SuppressWarnings("unchecked")
+        DataWriter<Object> writer = (DataWriter<Object>) resultWriter;
+        for (Object item : items) {
+            writer.writeEntry(item);
+        }
     }
 
     @SuppressWarnings("resource")