Uses of Interface
org.apache.ignite.lang.IgniteReducer

Packages that use IgniteReducer

Package	Description
org.apache.ignite	Contains entry-point Ignite & HPC APIs.
org.apache.ignite.internal	Contains main implementation.
org.apache.ignite.internal.processors.cache
org.apache.ignite.internal.processors.cache.query
org.apache.ignite.internal.processors.closure	TODO.
org.apache.ignite.internal.processors.streamer	TODO.
org.apache.ignite.internal.processors.streamer.task
org.apache.ignite.internal.util.future	Future related classes.
org.apache.ignite.internal.util.lang
org.apache.ignite.internal.util.typedef	Contains typedefs definitions for frequently used classes.
org.apache.ignite.streamer	Contains main Streaming APIs.

Uses of IgniteReducer in org.apache.ignite

Methods in org.apache.ignite with parameters of type IgniteReducer

Modifier and Type	Method and Description
<R1,R2,T> R2	IgniteCompute.apply(IgniteClosure<T,R1> job, Collection<? extends T> args, IgniteReducer<R1,R2> rdc) Executes provided closure job on nodes within this grid projection.
<R1,R2> R2	IgniteCompute.call(Collection<? extends IgniteCallable<R1>> jobs, IgniteReducer<R1,R2> rdc) Executes collection of jobs on nodes within this grid projection.

Uses of IgniteReducer in org.apache.ignite.internal

Methods in org.apache.ignite.internal with parameters of type IgniteReducer

Modifier and Type	Method and Description
<R1,R2,T> R2	IgniteComputeImpl.apply(IgniteClosure<T,R1> job, Collection<? extends T> args, IgniteReducer<R1,R2> rdc) Executes provided closure job on nodes within this grid projection.
<R1,R2> R2	IgniteComputeImpl.call(Collection<? extends IgniteCallable<R1>> jobs, IgniteReducer<R1,R2> rdc) Executes collection of jobs on nodes within this grid projection.

Uses of IgniteReducer in org.apache.ignite.internal.processors.cache

Methods in org.apache.ignite.internal.processors.cache that return IgniteReducer

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

Uses of IgniteReducer in org.apache.ignite.internal.processors.cache.query

Methods in org.apache.ignite.internal.processors.cache.query that return IgniteReducer

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

Methods in org.apache.ignite.internal.processors.cache.query with parameters of type IgniteReducer

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

Constructors in org.apache.ignite.internal.processors.cache.query with parameters of type IgniteReducer

Constructor and Description
GridCacheQueryBean(GridCacheQueryAdapter<?> qry, IgniteReducer<Object,Object> rdc, IgniteClosure<Object,Object> trans, Object[] args)
GridCacheQueryRequest(int cacheId, long id, String cacheName, GridCacheQueryType type, boolean fields, String clause, String clsName, IgniteBiPredicate<Object,Object> keyValFilter, IgniteReducer<Object,Object> rdc, IgniteClosure<Object,Object> trans, int pageSize, boolean incBackups, Object[] args, boolean incMeta, boolean keepPortable, UUID subjId, int taskHash)

Uses of IgniteReducer in org.apache.ignite.internal.processors.closure

Methods in org.apache.ignite.internal.processors.closure with parameters of type IgniteReducer

Modifier and Type	Method and Description
<T,R1,R2> ComputeTaskInternalFuture<R2>	GridClosureProcessor.callAsync(IgniteClosure<T,R1> job, Collection<? extends T> args, IgniteReducer<R1,R2> rdc, Collection<ClusterNode> nodes)
<R1,R2> ComputeTaskInternalFuture<R2>	GridClosureProcessor.forkjoinAsync(GridClosureCallMode mode, Collection<? extends Callable<R1>> jobs, IgniteReducer<R1,R2> rdc, Collection<ClusterNode> nodes)

Uses of IgniteReducer in org.apache.ignite.internal.processors.streamer

Methods in org.apache.ignite.internal.processors.streamer with parameters of type IgniteReducer

Modifier and Type	Method and Description
<R1,R2> R2	GridStreamerContextImpl.reduce(IgniteClosure<StreamerContext,R1> clo, IgniteReducer<R1,R2> rdc) Queries all streamer nodes deployed within grid.
<R1,R2> R2	GridStreamerContextDelegate.reduce(IgniteClosure<StreamerContext,R1> clo, IgniteReducer<R1,R2> rdc) Queries all streamer nodes deployed within grid.
<R1,R2> R2	GridStreamerContextImpl.reduce(IgniteClosure<StreamerContext,R1> clo, IgniteReducer<R1,R2> rdc, Collection<ClusterNode> nodes) Queries streamer nodes deployed within grid.
<R1,R2> R2	GridStreamerContextDelegate.reduce(IgniteClosure<StreamerContext,R1> clo, IgniteReducer<R1,R2> rdc, Collection<ClusterNode> nodes) Queries streamer nodes deployed within grid.

Uses of IgniteReducer in org.apache.ignite.internal.processors.streamer.task

Constructors in org.apache.ignite.internal.processors.streamer.task with parameters of type IgniteReducer

Constructor and Description
GridStreamerReduceTask(IgniteClosure<StreamerContext,R1> clos, IgniteReducer<R1,R2> rdc, String streamer)

Uses of IgniteReducer in org.apache.ignite.internal.util.future

Methods in org.apache.ignite.internal.util.future that return IgniteReducer

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

Methods in org.apache.ignite.internal.util.future with parameters of type IgniteReducer

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

Constructors in org.apache.ignite.internal.util.future with parameters of type IgniteReducer

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

Uses of IgniteReducer in org.apache.ignite.internal.util.lang

Classes in org.apache.ignite.internal.util.lang that implement IgniteReducer

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

Methods in org.apache.ignite.internal.util.lang that return IgniteReducer

Modifier and Type	Method and Description
static <T extends Number> IgniteReducer<T,Double>	GridFunc.avgReducer() Gets reducer closure that calculates arithmetic mean.
static IgniteReducer<String,String>	GridFunc.concatReducer(String delim) Gets reducer closure that concatenates strings using provided delimiter.
static <T,R> IgniteReducer<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> IgniteReducer<T,Double>	GridFunc.gavgReducer() Gets reducer closure that calculates geometric mean.
static <T extends Number> IgniteReducer<T,Double>	GridFunc.havgReducer() Gets reducer closure that calculates harmonic mean.
static <T> IgniteReducer<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> IgniteReducer<T,Double>	GridFunc.qavgReducer() Gets reducer closure that calculates quadratic mean.
static <T> IgniteReducer<T,T>	GridFunc.singleReducer() Gets reducer closure that collects only a single value and returns it without any transformations.
static IgniteReducer<BigDecimal,BigDecimal>	GridFunc.sumBigDecimalReducer() Gets reducer closure that calculates sum of all elements.
static IgniteReducer<BigInteger,BigInteger>	GridFunc.sumBigIntegerReducer() Gets reducer closure that calculates sum of all elements.
static IgniteReducer<Double,Double>	GridFunc.sumDoubleReducer() Gets reducer closure that calculates sum of all elements.
static IgniteReducer<Integer,Integer>	GridFunc.sumIntReducer() Gets reducer closure that calculates sum of integer elements.
static IgniteReducer<Long,Long>	GridFunc.sumLongReducer() Gets reducer closure that calculates sum of long integer elements.

Methods in org.apache.ignite.internal.util.lang with parameters of type IgniteReducer

Modifier and Type	Method and Description
static <T,R> R	GridFunc.awaitAll(long timeout, IgniteReducer<T,R> rdc, Collection<IgniteInternalFuture<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, IgniteReducer<? super X,Y> f) Reduces collection into single value using given for-all closure.

Uses of IgniteReducer in org.apache.ignite.internal.util.typedef

Subinterfaces of IgniteReducer in org.apache.ignite.internal.util.typedef

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

Classes in org.apache.ignite.internal.util.typedef that implement IgniteReducer

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

Uses of IgniteReducer in org.apache.ignite.streamer

Methods in org.apache.ignite.streamer with parameters of type IgniteReducer

Modifier and Type	Method and Description
<R1,R2> R2	StreamerContext.reduce(IgniteClosure<StreamerContext,R1> clo, IgniteReducer<R1,R2> rdc) Queries all streamer nodes deployed within grid.
<R1,R2> R2	StreamerContext.reduce(IgniteClosure<StreamerContext,R1> clo, IgniteReducer<R1,R2> rdc, Collection<ClusterNode> nodes) Queries streamer nodes deployed within grid.