OrderedCombiner implements ReaderSource<T> { public Class<T> getOutputClass() { return order.getOrderedClass(); } 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 testGetOutputClass() { OrderedCombiner instance = new OrderedCombiner<>(new TypeReader[0], new FakeType().getOrder("+value")); Class expResult = FakeType.class; Class result = instance.getOutputClass(); assertEquals(expResult, result); }