Class IgniteReducerX<E1,R>
- java.lang.Object
-
- org.apache.ignite.internal.util.lang.IgniteReducerX<E1,R>
-
- All Implemented Interfaces:
Serializable,IgniteReducer<E1,R>
- Direct Known Subclasses:
RX1
public abstract class IgniteReducerX<E1,R> extends Object implements IgniteReducer<E1,R>
Convenient reducer subclass that allows for thrown grid exception. This class implementsreduce()method that callsapplyx()method and properly wrapsIgniteCheckedExceptionintoGridClosureExceptioninstance.- See Also:
RX1, Serialized Form
-
-
Constructor Summary
Constructors Constructor Description IgniteReducerX()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description abstract Rapplyx()Reducer body that can throwIgniteCheckedException.Rreduce()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.apache.ignite.lang.IgniteReducer
collect
-
-
-
-
Method Detail
-
reduce
public R reduce()
Reduces collected values into one.- Specified by:
reducein interfaceIgniteReducer<E1,R>- Returns:
- Reduced value.
-
applyx
public abstract R applyx() throws IgniteCheckedException
Reducer body that can throwIgniteCheckedException.- Returns:
- Reducer return value.
- Throws:
IgniteCheckedException- Thrown in case of any error condition inside of the reducer.
-
-