org.gridgain.grid.util.lang

Class GridReducerX<E1,R>

java.lang.Object

org.gridgain.grid.util.lang.GridReducerX<E1,R>

All Implemented Interfaces:

Serializable, GridReducer<E1,R>

Direct Known Subclasses:

RX1

public abstract class GridReducerX<E1,R>
extends Object
implements GridReducer<E1,R>

Convenient reducer subclass that allows for thrown grid exception. This class implements reduce() method that calls applyx() method and properly wraps GridException into GridClosureException instance.

See Also:

RX1, Serialized Form

Constructor Summary

Constructors

Constructor and Description
GridReducerX()

Method Summary

Methods

Modifier and Type	Method and Description
abstract R	applyx() Reducer body that can throw GridException.
R	reduce() Reduces collected values into one.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.gridgain.grid.lang.GridReducer

collect

Constructor Detail

GridReducerX

public GridReducerX()

Method Detail

reduce

public R reduce()

Reduces collected values into one.

Specified by:

reduce in interface GridReducer<E1,R>

Returns:

Reduced value.

applyx

public abstract R applyx()
                  throws GridException

Reducer body that can throw GridException.

Returns:

Reducer return value.

Throws:

GridException - Thrown in case of any error condition inside of the reducer.