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

java.lang.Object
  org.gridgain.grid.lang.GridMetadataAwareAdapter
      org.gridgain.grid.lang.GridLambdaAdapter
          org.gridgain.grid.lang.GridOutClosure<R>
              org.gridgain.grid.lang.GridReducer<E1,R>
                  org.gridgain.grid.lang.GridReducerX<E1,R>

All Implemented Interfaces:

Serializable, Cloneable, Callable<R>, GridJob, GridMetadataAware, GridPeerDeployAware, GridLambda

Direct Known Subclasses:

RX1

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

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

Wiki & Forum:

Wiki
Forum

See Also:

RX1, Serialized Form

Constructor Summary

GridReducerX()

Method Summary

R	apply() Factory closure body.
abstract R	applyx() Reducer body that can throw GridException.

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

collect, curry, uncurry2, uncurry3

Methods inherited from class org.gridgain.grid.lang.GridOutClosure

andThen, andThen, call, cancel, execute, uncurry, uncurry2, uncurry3

Methods inherited from class org.gridgain.grid.lang.GridLambdaAdapter

classLoader, deployClass, peerDeployLike, withMeta

Methods inherited from class org.gridgain.grid.lang.GridMetadataAwareAdapter

addMeta, addMetaIfAbsent, addMetaIfAbsent, allMeta, clone, copyMeta, copyMeta, hasMeta, hasMeta, meta, putMetaIfAbsent, putMetaIfAbsent, readExternalMeta, removeMeta, removeMeta, replaceMeta, writeExternalMeta

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.gridgain.grid.GridMetadataAware

addMeta, addMetaIfAbsent, addMetaIfAbsent, allMeta, copyMeta, copyMeta, hasMeta, hasMeta, meta, putMetaIfAbsent, putMetaIfAbsent, removeMeta, removeMeta, replaceMeta

Constructor Detail

GridReducerX

public GridReducerX()

Method Detail

apply

public R apply()

Factory closure body.

Specified by:

apply in class GridOutClosure<R>

Returns:

Element.

applyx

public abstract R applyx()
                  throws GridException

Reducer body that can throw GridException.

Throws:

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

Returns:

Reducer return value.