Sorter extends StandardStep<T, T> implements NotificationListener { public static String getOutputClass(TupleFlowParameters parameters) { return parameters.getJSON().get("class", ""); } Sorter(Order<T> order);  Sorter(Order<T> order, Reducer<T> reducer);  Sorter(Order<T> order, Reducer<T> reducer, Processor<T> processor); @SuppressWarnings("unchecked")  Sorter(TupleFlowParameters parameters); final void requestMemoryWarnings(); void removeMemoryWarnings(); @Override final void handleNotification(Notification notification, Object handback); static void verify(TupleFlowParameters fullParameters, ErrorStore store); static String getInputClass(TupleFlowParameters parameters); static String getOutputClass(TupleFlowParameters parameters); static String[] getOutputOrder(TupleFlowParameters parameters); @Override String toString(); boolean needsReduce(); boolean needsFlush(); synchronized void flushIfNecessary(); @Override synchronized void process(T object); @Override synchronized void close(); synchronized void flush(); static final long DEFAULT_OBJECT_LIMIT; static final long DEFAULT_FILE_LIMIT; static final long DEFAULT_REDUCE_INTERVAL; static final double DEFAULT_MEMORY_FRACTION; }
@Test public void testGetOutputClass() { Parameters p = Parameters.create(); p.set("class", FakeType.class.toString()); String expResult = FakeType.class.toString(); String result = Sorter.getOutputClass(new FakeParameters(p)); assertEquals(expResult, result); }