Uses of Interface
org.gridgain.grid.lang.GridReducer

Packages that use GridReducer

Package	Description
org.gridgain.grid.cache.query	Contains APIs for creating and executing cache queries.
org.gridgain.grid.compute	Contains Compute Grid functionality.
org.gridgain.grid.kernal	Contains main implementation.
org.gridgain.grid.kernal.processors.cache
org.gridgain.grid.kernal.processors.cache.query
org.gridgain.grid.kernal.processors.closure	TODO.
org.gridgain.grid.kernal.processors.streamer	TODO.
org.gridgain.grid.kernal.processors.streamer.task
org.gridgain.grid.streamer	Contains main Streaming APIs.
org.gridgain.grid.util.future	Future related classes.
org.gridgain.grid.util.lang
org.gridgain.grid.util.typedef	Contains typedefs definitions for frequently used classes.

Uses of GridReducer in org.gridgain.grid.cache.query

Methods in org.gridgain.grid.cache.query with parameters of type GridReducer

Modifier and Type	Method and Description
<R> GridCacheQueryFuture<R>	GridCacheQuery.execute(GridReducer<T,R> rmtReducer, Object... args) Executes the query the same way as GridCacheQuery.execute(Object...) method but reduces result remotely.

Uses of GridReducer in org.gridgain.grid.compute

Methods in org.gridgain.grid.compute with parameters of type GridReducer

Modifier and Type	Method and Description
<R1,R2,T> GridFuture<R2>	GridCompute.apply(GridClosure<T,R1> job, Collection<? extends T> args, GridReducer<R1,R2> rdc) Executes provided closure job on nodes within this grid projection.
<R1,R2> GridFuture<R2>	GridCompute.call(Collection<? extends Callable<R1>> jobs, GridReducer<R1,R2> rdc) Executes collection of jobs on nodes within this grid projection.

Uses of GridReducer in org.gridgain.grid.kernal

Methods in org.gridgain.grid.kernal with parameters of type GridReducer

Modifier and Type	Method and Description
<R1,R2,T> GridFuture<R2>	GridComputeImpl.apply(GridClosure<T,R1> job, Collection<? extends T> args, GridReducer<R1,R2> rdc) Executes provided closure job on nodes within this grid projection.
<R1,R2> GridFuture<R2>	GridComputeImpl.call(Collection<? extends Callable<R1>> jobs, GridReducer<R1,R2> rdc) Executes collection of jobs on nodes within this grid projection.

Uses of GridReducer in org.gridgain.grid.kernal.processors.cache

Methods in org.gridgain.grid.kernal.processors.cache that return GridReducer

Modifier and Type	Method and Description
static GridReducer<Boolean,Boolean>	GridCacheUtils.boolReducer()
static <T> GridReducer<Collection<T>,Collection<T>>	GridCacheUtils.collectionsReducer() Gets reducer that aggregates collections.
static <K,V> GridReducer<Map<K,V>,Map<K,V>>	GridCacheUtils.mapsReducer(int size) Gets reducer that aggregates maps into one.
static <T> GridReducer<T,Collection<T>>	GridCacheUtils.objectsReducer() Gets reducer that aggregates items into collection.

Uses of GridReducer in org.gridgain.grid.kernal.processors.cache.query

Methods in org.gridgain.grid.kernal.processors.cache.query that return GridReducer

Modifier and Type	Method and Description
GridReducer<Object,Object>	GridCacheQueryBean.reducer()
GridReducer<Object,Object>	GridCacheQueryRequest.reducer()

Methods in org.gridgain.grid.kernal.processors.cache.query with parameters of type GridReducer

Modifier and Type	Method and Description
<R> GridCacheQueryFuture<R>	GridCacheQueryAdapter.execute(GridReducer<T,R> rmtReducer, Object... args) Executes the query the same way as GridCacheQuery.execute(Object...) method but reduces result remotely.

Constructors in org.gridgain.grid.kernal.processors.cache.query with parameters of type GridReducer

Constructor and Description
GridCacheQueryBean(GridCacheQueryAdapter<?> qry, GridReducer<Object,Object> rdc, GridClosure<Object,Object> trans, Object[] args)
GridCacheQueryRequest(long id, String cacheName, GridCacheQueryType type, boolean fields, String clause, String clsName, GridBiPredicate<Object,Object> keyValFilter, GridPredicate<GridCacheEntry<Object,Object>> prjFilter, GridReducer<Object,Object> rdc, GridClosure<Object,Object> trans, int pageSize, boolean incBackups, Object[] args, boolean incMeta)

Uses of GridReducer in org.gridgain.grid.kernal.processors.closure

Methods in org.gridgain.grid.kernal.processors.closure with parameters of type GridReducer

Modifier and Type	Method and Description
<T,R1,R2> GridFuture<R2>	GridClosureProcessor.callAsync(GridClosure<T,R1> job, Collection<? extends T> args, GridReducer<R1,R2> rdc, Collection<GridNode> nodes)
<R1,R2> GridFuture<R2>	GridClosureProcessor.forkjoinAsync(GridClosureCallMode mode, Collection<? extends Callable<R1>> jobs, GridReducer<R1,R2> rdc, Collection<GridNode> nodes)

Uses of GridReducer in org.gridgain.grid.kernal.processors.streamer

Methods in org.gridgain.grid.kernal.processors.streamer with parameters of type GridReducer

Modifier and Type	Method and Description
<R1,R2> R2	GridStreamerContextDelegate.reduce(GridClosure<GridStreamerContext,R1> clo, GridReducer<R1,R2> rdc) Queries all streamer nodes deployed within grid.
<R1,R2> R2	GridStreamerContextImpl.reduce(GridClosure<GridStreamerContext,R1> clo, GridReducer<R1,R2> rdc) Queries all streamer nodes deployed within grid.
<R1,R2> R2	GridStreamerContextDelegate.reduce(GridClosure<GridStreamerContext,R1> clo, GridReducer<R1,R2> rdc, Collection<GridNode> nodes) Queries streamer nodes deployed within grid.
<R1,R2> R2	GridStreamerContextImpl.reduce(GridClosure<GridStreamerContext,R1> clo, GridReducer<R1,R2> rdc, Collection<GridNode> nodes) Queries streamer nodes deployed within grid.

Uses of GridReducer in org.gridgain.grid.kernal.processors.streamer.task

Constructors in org.gridgain.grid.kernal.processors.streamer.task with parameters of type GridReducer

Constructor and Description
GridStreamerReduceTask(GridClosure<GridStreamerContext,R1> clos, GridReducer<R1,R2> rdc, String streamer)

Uses of GridReducer in org.gridgain.grid.streamer

Methods in org.gridgain.grid.streamer with parameters of type GridReducer

Modifier and Type	Method and Description
<R1,R2> R2	GridStreamerContext.reduce(GridClosure<GridStreamerContext,R1> clo, GridReducer<R1,R2> rdc) Queries all streamer nodes deployed within grid.
<R1,R2> R2	GridStreamerContext.reduce(GridClosure<GridStreamerContext,R1> clo, GridReducer<R1,R2> rdc, Collection<GridNode> nodes) Queries streamer nodes deployed within grid.

Uses of GridReducer in org.gridgain.grid.util.future

Methods in org.gridgain.grid.util.future that return GridReducer

Modifier and Type	Method and Description
GridReducer<T,R>	GridCompoundFuture.reducer() Gets optional reducer.

Methods in org.gridgain.grid.util.future with parameters of type GridReducer

Modifier and Type	Method and Description
void	GridCompoundFuture.reducer(GridReducer<T,R> rdc) Sets optional reducer.

Constructors in org.gridgain.grid.util.future with parameters of type GridReducer

Constructor and Description
GridCompoundFuture(GridKernalContext ctx, GridReducer<T,R> rdc)
GridCompoundFuture(GridKernalContext ctx, GridReducer<T,R> rdc, Iterable<GridFuture<T>> futs)
GridCompoundIdentityFuture(GridKernalContext ctx, GridReducer<T,T> rdc)
GridCompoundIdentityFuture(GridKernalContext ctx, GridReducer<T,T> rdc, Iterable<GridFuture<T>> futs)

Uses of GridReducer in org.gridgain.grid.util.lang

Classes in org.gridgain.grid.util.lang that implement GridReducer

Modifier and Type	Class and Description
class	GridReducerX<E1,R> Convenient reducer subclass that allows for thrown grid exception.

Methods in org.gridgain.grid.util.lang that return GridReducer

Modifier and Type	Method and Description
static <T extends Number> GridReducer<T,Double>	GridFunc.avgReducer() Gets reducer closure that calculates arithmetic mean.
static GridReducer<String,String>	GridFunc.concatReducer(String delim) Gets reducer closure that concatenates strings using provided delimiter.
static <T,R> GridReducer<T,R>	GridFunc.continuousReducer(R elem) Gets reducer which always returns true from collect(Object) method and passed in element from reduce() method.
static <T extends Number> GridReducer<T,Double>	GridFunc.gavgReducer() Gets reducer closure that calculates geometric mean.
static <T extends Number> GridReducer<T,Double>	GridFunc.havgReducer() Gets reducer closure that calculates harmonic mean.
static <T> GridReducer<T,T>	GridFunc.identityReducer(T elem) Gets reducer which always returns true from collect(Object) method and passed in element from reduce() method.
static <T extends Number> GridReducer<T,Double>	GridFunc.qavgReducer() Gets reducer closure that calculates quadratic mean.
static <T> GridReducer<T,T>	GridFunc.singleReducer() Gets reducer closure that collects only a single value and returns it without any transformations.
static GridReducer<BigDecimal,BigDecimal>	GridFunc.sumBigDecimalReducer() Gets reducer closure that calculates sum of all elements.
static GridReducer<BigInteger,BigInteger>	GridFunc.sumBigIntegerReducer() Gets reducer closure that calculates sum of all elements.
static GridReducer<Double,Double>	GridFunc.sumDoubleReducer() Gets reducer closure that calculates sum of all elements.
static GridReducer<Integer,Integer>	GridFunc.sumIntReducer() Gets reducer closure that calculates sum of integer elements.
static GridReducer<Long,Long>	GridFunc.sumLongReducer() Gets reducer closure that calculates sum of long integer elements.

Methods in org.gridgain.grid.util.lang with parameters of type GridReducer

Modifier and Type	Method and Description
static <T,R> R	GridFunc.awaitAll(long timeout, GridReducer<T,R> rdc, Collection<GridFuture<T>> futs) Awaits for all futures to complete and optionally reduces all results into one.
static <X,Y> Y	GridFunc.reduce(Iterable<? extends X> c, GridReducer<? super X,Y> f) Reduces collection into single value using given for-all closure.

Uses of GridReducer in org.gridgain.grid.util.typedef

Subinterfaces of GridReducer in org.gridgain.grid.util.typedef

Modifier and Type	Interface and Description
interface	R1<E1,R> Defines alias for GridReducer by extending it.

Classes in org.gridgain.grid.util.typedef that implement GridReducer

Modifier and Type	Class and Description
class	RX1<E1,R> Defines alias for GridReducerX by extending it.