Sorter extends StandardStep<T, T> implements NotificationListener { @Override public synchronized void process(T object) throws IOException { objects.add(object); flushIfNecessary(); } 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 testProcess() throws Exception { FakeType object = new FakeType(); Sorter<FakeType> instance = new Sorter<FakeType>(new FakeType().getOrder("+document", "+length")); instance.process(object); }