Package org.apache.ignite.internal.util.lang

Class IgniteReducer3X<E1,E2,E3,R>

java.lang.Object

org.apache.ignite.internal.util.lang.IgniteReducer3X<E1,E2,E3,R>

All Implemented Interfaces:

Serializable, IgniteReducer3<E1,E2,E3,R>, IgniteOutClosure<R>

Direct Known Subclasses:

RX3

public abstract class IgniteReducer3X<E1,E2,E3,R>
extends Object
implements IgniteReducer3<E1,E2,E3,R>

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

See Also:

RX3, Serialized Form

Constructor Summary

Constructors

Constructor	Description
IgniteReducer3X()

Method Summary

Modifier and Type	Method	Description
R	apply()	Closure body.
abstract R	applyx()	Reducer body that can throw IgniteCheckedException.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.internal.util.lang.IgniteReducer3

collect

Constructor Detail

IgniteReducer3X

public IgniteReducer3X()

Method Detail

apply

public R apply()

Closure body.

Specified by:

apply in interface IgniteOutClosure<E1>

Returns:

Return value.

applyx

public abstract R applyx()
                  throws IgniteCheckedException

Reducer body that can throw IgniteCheckedException.

Returns:

Reducer return value.

Throws:

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