## Uses of Interface
org.apache.ignite.lang.IgniteClosure

Packages that use IgniteClosure
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.igfs | Contains high performance file system processer.
org.apache.ignite.internal.processors.streamer | TODO.
org.apache.ignite.internal.processors.streamer.task |
org.apache.ignite.internal.util | System-wide utility routine and helper classes.
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.lang | Contains general language constructs and functional APIs for distributed computations.
org.apache.ignite.streamer | Contains main Streaming APIs.
org.apache.ignite.streamer.index | Contains APIs for indexing of streamer windows.

### Uses of IgniteClosure in org.apache.ignite

Methods in org.apache.ignite with parameters of type IgniteClosure
Modifier and Type | Method and Description
--- | ---
`<T,R> Collection<R>` | IgniteCompute.`apply(IgniteClosure<T,R> job, Collection<? extends T> args)` Executes provided closure job on nodes within this grid projection.
`<R,T> R` | IgniteCompute.`apply(IgniteClosure<T,R> job, T arg)` Executes provided closure job on a node in this grid projection.
`<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.
`<R,T> Collection<R>` | IgniteCompute.`broadcast(IgniteClosure<T,R> job, T arg)` Broadcasts given closure job with passed in argument to all nodes in grid projection.

### Uses of IgniteClosure in org.apache.ignite.internal

Methods in org.apache.ignite.internal with parameters of type IgniteClosure
Modifier and Type | Method and Description
--- | ---
`<T,R> Collection<R>` | IgniteComputeImpl.`apply(IgniteClosure<T,R> job, Collection<? extends T> args)` Executes provided closure job on nodes within this grid projection.
`<R,T> R` | IgniteComputeImpl.`apply(IgniteClosure<T,R> job, T arg)` Executes provided closure job on a node in this grid projection.
`<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.
`<R,T> Collection<R>` | IgniteComputeImpl.`broadcast(IgniteClosure<T,R> job, T arg)` Broadcasts given closure job with passed in argument to all nodes in grid projection.
`<T> IgniteInternalFuture<T>` | IgniteInternalFuture.`chain(IgniteClosure<? super IgniteInternalFuture<R>,T> doneCb)` Make a chained future to convert result of this future (when complete) into a new format.
`static Ignite` | IgnitionEx.`startInterop(String springCfgPath, String gridName, IgniteClosure<IgniteConfiguration,IgniteConfiguration> cfgClo)` Start Grid for interop scenario.

### Uses of IgniteClosure in org.apache.ignite.internal.processors.cache

Methods in org.apache.ignite.internal.processors.cache that return IgniteClosure
Modifier and Type | Method and Description
--- | ---
`static <K,V> IgniteClosure<K,javax.cache.Cache.Entry<K,V>>` | GridCacheUtils.`cacheKey2Entry(GridCacheContext<K,V> ctx)` Gets closure which returns `Entry` given cache key.
`static <K,V> IgniteClosure<GridCacheEntryEx<K,V>,K>` | GridCacheUtils.`entry2Key()`
`static <K,V> IgniteClosure<Integer,IgnitePredicate<javax.cache.Cache.Entry<K,V>>[]>` | GridCacheUtils.`factory()` Entry predicate factory mostly used for deserialization.
`static <K,V> IgniteClosure<GridCacheEntryInfo<K,V>,K>` | GridCacheUtils.`info2Key()`
`static <K,V> IgniteClosure<GridDhtLocalPartition<K,V>,GridDhtPartitionState>` | GridCacheUtils.`part2state()`
`static <K,V> IgniteClosure<IgniteTxEntry<K,V>,GridCacheEntryEx<K,V>>` | GridCacheUtils.`tx2entry()`
`static <K,V> IgniteClosure<IgniteTxEntry<K,V>,K>` | GridCacheUtils.`tx2key()`
`static <K,V> IgniteClosure<IgniteTxEntry<K,V>,byte[]>` | GridCacheUtils.`tx2keyBytes()`
`static <K,V> IgniteClosure<IgniteInternalTx<K,V>,GridCacheVersion>` | GridCacheUtils.`tx2xidVersion()`
`static <K,V> IgniteClosure<Collection<IgniteTxEntry<K,V>>,Collection<K>>` | GridCacheUtils.`txCol2Key()`
`static IgniteClosure<Integer,GridCacheVersion[]>` | GridCacheUtils.`versionArrayFactory()`

Constructors in org.apache.ignite.internal.processors.cache with parameters of type IgniteClosure
Constructor and Description
`GridCacheIterator(GridCacheContext<K,V> cctx, Iterable<? extends javax.cache.Cache.Entry<K,V>> c, IgniteClosure<javax.cache.Cache.Entry<K,V>,T> trans, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)`

### Uses of IgniteClosure in org.apache.ignite.internal.processors.cache.query

Methods in org.apache.ignite.internal.processors.cache.query that return IgniteClosure
Modifier and Type | Method and Description
--- | ---
`IgniteClosure<Object,Object>` | GridCacheQueryBean.`transform()`
`IgniteClosure<Object,Object>` | GridCacheQueryRequest.`transformer()`

Methods in org.apache.ignite.internal.processors.cache.query with parameters of type IgniteClosure
Modifier and Type | Method and Description
--- | ---
`<R> CacheQueryFuture<R>` | CacheQuery.`execute(IgniteClosure<T,R> rmtTransform, Object... args)` Executes the query the same way as `CacheQuery.execute(Object...)` method but transforms result remotely.
`<R> CacheQueryFuture<R>` | GridCacheQueryAdapter.`execute(IgniteClosure<T,R> rmtTransform, Object... args)` Executes the query the same way as `CacheQuery.execute(Object...)` method but transforms result remotely.

Constructors in org.apache.ignite.internal.processors.cache.query with parameters of type IgniteClosure
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, IgnitePredicate<javax.cache.Cache.Entry<Object,Object>> prjFilter, IgniteReducer<Object,Object> rdc, IgniteClosure<Object,Object> trans, int pageSize, boolean incBackups, Object[] args, boolean incMeta, boolean keepPortable, UUID subjId, int taskHash)`

### Uses of IgniteClosure in org.apache.ignite.internal.processors.closure

Methods in org.apache.ignite.internal.processors.closure with parameters of type IgniteClosure
Modifier and Type | Method and Description
--- | ---
`<T,R> IgniteInternalFuture<Collection<R>>` | GridClosureProcessor.`broadcast(IgniteClosure<T,R> job, T arg, Collection<ClusterNode> nodes)`
`<T,R> IgniteInternalFuture<Collection<R>>` | GridClosureProcessor.`broadcastNoFailover(IgniteClosure<T,R> job, T arg, Collection<ClusterNode> nodes)`
`<T,R> ComputeTaskInternalFuture<Collection<R>>` | GridClosureProcessor.`callAsync(IgniteClosure<T,R> job, Collection<? extends T> args, Collection<ClusterNode> nodes)`
`<T,R> ComputeTaskInternalFuture<R>` | GridClosureProcessor.`callAsync(IgniteClosure<T,R> job, T arg, Collection<ClusterNode> nodes)`
`<T,R1,R2> ComputeTaskInternalFuture<R2>` | GridClosureProcessor.`callAsync(IgniteClosure<T,R1> job, Collection<? extends T> args, IgniteReducer<R1,R2> rdc, Collection<ClusterNode> nodes)`

### Uses of IgniteClosure in org.apache.ignite.internal.processors.igfs

Methods in org.apache.ignite.internal.processors.igfs with parameters of type IgniteClosure
Modifier and Type | Method and Description
--- | ---
`IgfsFileInfo` | IgfsMetaManager.`updateInfo(IgniteUuid fileId, IgniteClosure<IgfsFileInfo,IgfsFileInfo> c)` Update file info in cache.

### Uses of IgniteClosure in org.apache.ignite.internal.processors.streamer

Methods in org.apache.ignite.internal.processors.streamer with parameters of type IgniteClosure
Modifier and Type | Method and Description
--- | ---
`<R> Collection<R>` | GridStreamerContextDelegate.`query(IgniteClosure<StreamerContext,R> clo)` Queries all streamer nodes deployed within grid.
`<R> Collection<R>` | GridStreamerContextImpl.`query(IgniteClosure<StreamerContext,R> clo)` Queries all streamer nodes deployed within grid.
`<R> Collection<R>` | GridStreamerContextDelegate.`query(IgniteClosure<StreamerContext,R> clo, Collection<ClusterNode> nodes)` Queries streamer nodes deployed within grid.
`<R> Collection<R>` | GridStreamerContextImpl.`query(IgniteClosure<StreamerContext,R> clo, Collection<ClusterNode> nodes)` Queries 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)` Queries all 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.
`<R1,R2> R2` | GridStreamerContextImpl.`reduce(IgniteClosure<StreamerContext,R1> clo, IgniteReducer<R1,R2> rdc, Collection<ClusterNode> nodes)` Queries streamer nodes deployed within grid.

### Uses of IgniteClosure in org.apache.ignite.internal.processors.streamer.task

Constructors in org.apache.ignite.internal.processors.streamer.task with parameters of type IgniteClosure
Constructor and Description
`GridStreamerQueryTask(IgniteClosure<StreamerContext,R> qryClos, String streamer)`
`GridStreamerReduceTask(IgniteClosure<StreamerContext,R1> clos, IgniteReducer<R1,R2> rdc, String streamer)`

### Uses of IgniteClosure in org.apache.ignite.internal.util

Methods in org.apache.ignite.internal.util that return IgniteClosure
Modifier and Type | Method and Description
--- | ---
`static IgniteClosure<UUID,ClusterNode>` | IgniteUtils.`id2Node(GridKernalContext ctx)`

### Uses of IgniteClosure in org.apache.ignite.internal.util.future

Methods in org.apache.ignite.internal.util.future with parameters of type IgniteClosure
Modifier and Type | Method and Description
--- | ---
`<T> IgniteFuture<T>` | IgniteFutureImpl.`chain(IgniteClosure<? super IgniteFuture<V>,T> doneCb)` Make a chained future to convert result of this future (when complete) into a new format.
`<T> IgniteInternalFuture<T>` | GridFutureAdapter.`chain(IgniteClosure<? super IgniteInternalFuture<R>,T> doneCb)` Make a chained future to convert result of this future (when complete) into a new format.
`<T> IgniteInternalFuture<T>` | GridFutureAdapterEx.`chain(IgniteClosure<? super IgniteInternalFuture<R>,T> doneCb)` Make a chained future to convert result of this future (when complete) into a new format.
`<R> IgniteInternalFuture<R>` | GridFinishedFutureEx.`chain(IgniteClosure<? super IgniteInternalFuture<T>,R> doneCb)` Make a chained future to convert result of this future (when complete) into a new format.
`<R> IgniteInternalFuture<R>` | GridFinishedFuture.`chain(IgniteClosure<? super IgniteInternalFuture<T>,R> doneCb)` Make a chained future to convert result of this future (when complete) into a new format.

Constructors in org.apache.ignite.internal.util.future with parameters of type IgniteClosure
Constructor and Description
`GridFutureChainListener(GridKernalContext ctx, GridFutureAdapter<R> fut, IgniteClosure<? super IgniteInternalFuture<T>,R> doneCb)` Constructs chain listener.

### Uses of IgniteClosure in org.apache.ignite.internal.util.lang

Classes in org.apache.ignite.internal.util.lang that implement IgniteClosure
Modifier and Type | Class and Description
--- | ---
`class` | `IgniteClosureX<E,R>` Convenient closure subclass that allows for thrown grid exception.

Methods in org.apache.ignite.internal.util.lang that return IgniteClosure
Modifier and Type | Method and Description
--- | ---
`static <X> IgniteClosure<X,Boolean>` | GridFunc.`as(IgnitePredicate<? super X> p)` Converts given predicate to closure.
`static <T> IgniteClosure<Callable<T>,IgniteOutClosure<T>>` | GridFunc.`c2c()` Returns closure that converts `Callable` to `IgniteOutClosure`.
`static <K,V> IgniteClosure<javax.cache.Cache.Entry<K,V>,V>` | GridFunc.`cacheEntry2Get()` Gets closure that returns value for an entry.
`static <K,V> IgniteClosure<javax.cache.Cache.Entry<K,V>,K>` | GridFunc.`cacheEntry2Key()` Gets closure that returns key for cache entry.
`static <K,V> IgniteClosure<javax.cache.Cache.Entry<K,V>,V>` | GridFunc.`cacheEntry2Peek()` Gets closure that returns result of `org.apache.ignite.cache.Entry#peek()` method.
`static <T,R> IgniteClosure<T,R>` | GridFunc.`cInvoke(String mtdName, Object... args)` Creates closure that will reflectively call a method with the given name on closure's argument and return result of that call.
`static IgniteClosure<Object,Class<?>>` | GridFunc.`clazz()` Gets closure that converts object to its runtime class.
`static <D,B,C> IgniteClosure<D,C>` | GridFunc.`compose(IgniteClosure<? super D,? extends B> f, IgniteClosure<? super B,C> g)` Composes two closures into one.
`static <T1,R> IgniteClosure<T1,R>` | GridFunc.`constant1(R val)` Gets closure that returns constant value.
`static <T1,T2,R> IgniteClosure<T2,R>` | GridFunc.`curry(IgniteBiClosure<? super T1,? super T2,R> f, T1 e)` Curries given closure.
`static <K,V> IgniteClosure<K,V>` | GridFunc.`forMap(Map<? extends K,? extends V> m)` Gets closure that wraps given map access, i.e. returns map's value assuming that free variable is a map's key.
`static <K,V> IgniteClosure<K,V>` | GridFunc.`forMap(Map<? extends K,? extends V> m, Callable<V> c)` Gets closure that wraps given map's access, i.e. returns map's value assuming that free variable is a map's key or default value produced by optional factory closure if key has no mapping.
`static <T> IgniteClosure<IgniteInternalFuture<T>,Future<T>>` | GridFunc.`future()` Gets closure that converts `IgniteInternalFuture` to `Future`.
`static IgniteClosure<UUID,String>` | GridFunc.`id2id8()` Gets closure which converts node ID to node ID8 representation (shorter and good enough).
`static <T> IgniteClosure<T,T>` | GridFunc.`identity()` Gets identity closure, i.e. the closure that returns its variable value.
`static <K> IgniteClosure<Map.Entry<K,?>,K>` | GridFunc.`mapEntry2Key()` Gets closure that returns key for an entry.
`static <V> IgniteClosure<Map.Entry<?,V>,V>` | GridFunc.`mapEntry2Value()` Gets closure that returns value for an entry.
`static IgniteClosure<ClusterNode,UUID>` | GridFunc.`node2id()` Gets closure which converts node to node ID.
`static IgniteClosure<ClusterNode,String>` | GridFunc.`node2id8()` Gets closure which converts node to node ID8 representation (shorter and good enough).
`static IgniteClosure<ClusterGroup,IgnitePredicate<ClusterNode>>` | GridFunc.`predicate()` Gets closure that transform a grid projection into its predicate.
`static IgniteClosure<Runnable,GridAbsClosure>` | GridFunc.`r2c()` Returns closure that converts `Runnable` to `GridAbsClosure`.
`static <T> IgniteClosure<T,String>` | GridFunc.`string()` Gets closure that return `toString()` value for its free variable.

Methods in org.apache.ignite.internal.util.lang that return types with arguments of type IgniteClosure
Modifier and Type | Method and Description
--- | ---
`static <T1,T2,R> Collection<IgniteClosure<T2,R>>` | GridFunc.`curry2(Collection<? extends IgniteBiClosure<? super T1,T2,R>> iter, T1 arg)` Curries collection of closures with given argument.

Methods in org.apache.ignite.internal.util.lang with parameters of type IgniteClosure
Modifier and Type | Method and Description
--- | ---
`static <T> IgnitePredicate<T>` | GridFunc.`as(IgniteClosure<? super T,Boolean> c)` Converts given closure to predicate.
`static <D,B,C> IgniteClosure<D,C>` | GridFunc.`compose(IgniteClosure<? super D,? extends B> f, IgniteClosure<? super B,C> g)` Composes two closures into one.
`static <D,B,C> IgniteClosure<D,C>` | GridFunc.`compose(IgniteClosure<? super D,? extends B> f, IgniteClosure<? super B,C> g)` Composes two closures into one.
`static <X,Y> IgnitePredicate<X>` | GridFunc.`compose(IgnitePredicate<? super Y> p, IgniteClosure<? super X,? extends Y> f)` Gets a predicate that is composed of given predicate and closure.
`static <T,R> Collection<IgniteOutClosure<R>>` | GridFunc.`curry(IgniteClosure<? super T,R> c, Collection<? extends T> args)` Curries collection of closures with given collection of arguments.
`static <T,R> IgniteOutClosure<R>` | GridFunc.`curry(IgniteClosure<? super T,R> f, T e)` Curries given closure.
`static <T,R> Collection<IgniteOutClosure<R>>` | GridFunc.`curry(int cnt, IgniteClosure<? super T,R> c, IgniteOutClosure<T> pdc)` Curries collection of closures with given collection of arguments.
`static <V,Y> Y` | GridFunc.`find(Iterable<? extends V> c, Y dfltVal, IgniteClosure<? super V,Y> f, IgnitePredicate<? super V>... p)` Finds, transforms and returns first element in given collection for which any of the provided predicates evaluates to `true`.
`static <V,Y> Y` | GridFunc.`find(V[] c, Y dfltVal, IgniteClosure<? super V,Y> f, IgnitePredicate<? super V>... p)` Finds, transforms and returns first element in given array for which any of the provided predicates evaluates to `true`.
`static <T1,T2> GridIterator<T2>` | GridFunc.`iterator(Iterable<? extends T1> c, IgniteClosure<? super T1,T2> trans, boolean readOnly, IgnitePredicate<? super T1>... p)` Creates and returns transforming iterator from given collection and optional filtering predicates.
`static <T1,T2> Iterator<T2>` | GridFunc.`iterator(Iterator<? extends T1> c, IgniteClosure<? super T1,T2> trans, boolean readOnly, IgnitePredicate<? super T1>... p)`
`static <X,Y> Collection<Y>` | GridFunc.`transform(Collection<? extends X> c, IgniteClosure<? super X,Y> f)` Transforms one collection to another using provided closure.
`static <X,Y> Collection<Y>` | GridFunc.`transform(Collection<? extends X> c, IgniteClosure<? super X,Y> f, IgnitePredicate<? super X>... p)` Transforms one collection to another using provided closure and optional set of predicates.
`static <X,Y> Collection<Y>` | GridFunc.`transform(Collection<Y> to, Iterable<? extends X> from, IgniteClosure<? super X,Y> f, IgnitePredicate<? super X>... p)` Transforms one collection to another using provided closure and predicate.
`static <X,Y> Collection<Y>` | GridFunc.`transform(X[] c, IgniteClosure<? super X,Y> f)` Transforms an array to read only collection using provided closure.
`static <T1,T2> List<T2>` | GridFunc.`transformList(Collection<? extends T1> c, IgniteClosure<? super T1,T2> trans, IgnitePredicate<? super T1>... p)` Creates a view on given list with provided transformer and predicates.
`static <T1,T2> Set<T2>` | GridFunc.`transformSet(Collection<? extends T1> c, IgniteClosure<? super T1,T2> trans, IgnitePredicate<? super T1>... p)` Creates a view on given set with provided transformer and predicates.
`static <K0,K extends K0,V0,V extends V0> Map<K,V>` | GridFunc.`viewAsMap(Set<K> c, IgniteClosure<? super K,V> mapClo, IgnitePredicate<? super K>... p)` Read-only map view of a collection.
`static <T1,T2> List<T2>` | GridFunc.`viewListReadOnly(List<? extends T1> c, IgniteClosure<? super T1,T2> trans)` Creates read-only light-weight view on given list with provided transformation.
`static <T1,T2> Collection<T2>` | GridFunc.`viewReadOnly(Collection<? extends T1> c, IgniteClosure<? super T1,T2> trans, IgnitePredicate<? super T1>... p)` Creates read-only light-weight view on given collection with transformation and provided predicates.
`static <K0,K extends K0,V0,V extends V0,V1> Map<K,V1>` | GridFunc.`viewReadOnly(Map<K,V> m, IgniteClosure<V,V1> trans, IgnitePredicate<? super K>... p)` Read-only view on map that supports transformation of values and key filtering.
`static <T,R> Collection<IgniteOutClosure<R>>` | GridFunc.`yield(Collection<? extends T> c, IgniteClosure<? super T,R> f)` Given collection of items and a closure this method returns read only collection of closures where each closure is closed on an element of the initial collection.
`static <T,R> Collection<IgniteOutClosure<R>>` | GridFunc.`yield(T[] c, IgniteClosure<? super T,R> f)` Given array of items and a closure this method returns collection of closures where each closure is closed on a element of the array.

Method parameters in org.apache.ignite.internal.util.lang with type arguments of type IgniteClosure
Modifier and Type | Method and Description
--- | ---
`static <T,R> Collection<IgniteOutClosure<R>>` | GridFunc.`curry(Collection<? extends IgniteClosure<? super T,R>> closures, Collection<? extends T> args)` Curries collection of closures with given collection of arguments.
`static <T,R> Collection<IgniteOutClosure<R>>` | GridFunc.`curry(Collection<? extends IgniteClosure<? super T,R>> iter, T arg)` Curries collection of closures with given argument.

### Uses of IgniteClosure in org.apache.ignite.internal.util.typedef

Subinterfaces of IgniteClosure in org.apache.ignite.internal.util.typedef
Modifier and Type | Interface and Description
--- | ---
`interface` | `C1<E1,R>` Defines `alias` for `IgniteClosure` by extending it.

Classes in org.apache.ignite.internal.util.typedef that implement IgniteClosure
Modifier and Type | Class and Description
--- | ---
`class` | `CX1<E1,R>` Defines `alias` for `IgniteClosureX` by extending it.

### Uses of IgniteClosure in org.apache.ignite.lang

Methods in org.apache.ignite.lang with parameters of type IgniteClosure
Modifier and Type | Method and Description
--- | ---
`<T> IgniteFuture<T>` | IgniteFuture.`chain(IgniteClosure<? super IgniteFuture<V>,T> doneCb)` Make a chained future to convert result of this future (when complete) into a new format.

### Uses of IgniteClosure in org.apache.ignite.streamer

Methods in org.apache.ignite.streamer with parameters of type IgniteClosure
Modifier and Type | Method and Description
--- | ---
`<R> Collection<R>` | StreamerContext.`query(IgniteClosure<StreamerContext,R> clo)` Queries all streamer nodes deployed within grid.
`<R> Collection<R>` | StreamerContext.`query(IgniteClosure<StreamerContext,R> clo, Collection<ClusterNode> nodes)` Queries streamer nodes deployed within grid.
`<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.

### Uses of IgniteClosure in org.apache.ignite.streamer.index

Fields in org.apache.ignite.streamer.index declared as IgniteClosure
Modifier and Type | Field and Description
--- | ---
`protected IgniteClosure<StreamerIndexEntry<E,K,V>,K>` | StreamerIndexProviderAdapter.`entryToKey`
`protected IgniteClosure<StreamerIndexEntry<E,K,V>,V>` | StreamerIndexProviderAdapter.`entryToVal`

2015 Copyright © Apache Software Foundation

Follow @ApacheIgnite

Ignite Fabric | : ver. 1.0.0-RC1
Release Date | : February 17 2015