org.openspaces.core.executor.support
Class MinReducer<T extends Number>

java.lang.Object
  org.openspaces.core.executor.support.MinReducer<T>

All Implemented Interfaces:

AsyncResultsReducer<T,T>

public class MinReducer<T extends Number>
extends Object
implements AsyncResultsReducer<T,T>

A default implementation of a reducer that returnt the minimum of T.

Author:

kimchy

Constructor Summary

MinReducer(Class<T> reduceType)

Method Summary

MinReducer	ignoreExceptions() Causes the reducer to ignore exceptions and just sum the results that succeeded.
T	reduce(List<AsyncResult<T>> results)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MinReducer

public MinReducer(Class<T> reduceType)
           throws IllegalArgumentException

Throws:

IllegalArgumentException

Method Detail

ignoreExceptions

public MinReducer ignoreExceptions()

Causes the reducer to ignore exceptions and just sum the results that succeeded.

reduce

public T reduce(List<AsyncResult<T>> results)
                        throws Exception

Specified by:

reduce in interface AsyncResultsReducer<T extends Number,T extends Number>

Throws:

Exception