OrderedCombiner implements ReaderSource<T> { public void run() throws IOException { if (inputs.length == 0) { return; } source = order.orderedCombiner(Arrays.asList(inputs), false); try { source.setProcessor(processor); } catch (IncompatibleProcessorException e) { throw (IOException) new IOException("Wasn't able to link to this processor object.").initCause(e); } source.run(); if (closeOnExit) { Linkage.close(processor); } close(); } OrderedCombiner(TypeReader<T>[] inputs, FileOrderedReader<T>[] files, Order<T> order, Processor<T> processor, boolean closeOnExit); @SuppressWarnings(value = "unchecked")  OrderedCombiner(TypeReader<T>[] inputs, Order<T> order, Processor<T> processor); @SuppressWarnings(value = "unchecked")  OrderedCombiner(TypeReader<T>[] inputs, Order<T> order); Class<T> getOutputClass(); void setProcessor(final Step processor); static OrderedCombiner combineFromFiles(List<String> filenames, Order<S> order); static OrderedCombiner<S> combineFromFileObjs(List<File> filenames, Order<S> order); @SuppressWarnings(value = "unchecked") static OrderedCombiner<S> combineFromFiles(List<String> filenames, Order<S> order, Processor<S> processor, boolean closeOnExit, int bufferSize); @SuppressWarnings(value = "unchecked") static OrderedCombiner<S> combineFromFiles(List<String> filenames); static OrderedCombiner<S> combineFromFiles(List<String> filenames, Order<S> order, Processor<S> processor); T read(); @SuppressWarnings("unchecked") void close(); void run(); CompressionType getCompression(); public Step processor; }
@Test public void testRun() throws Exception { OrderedCombiner instance = new OrderedCombiner<>(new TypeReader[0], new FakeType().getOrder("+value")); instance.run(); }