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

Packages that use IgniteClosure
org.apache.ignite: Contains entry-point Ignite & HPC APIs.
org.apache.ignite.cache.query: Contains APIs for creating and executing cache queries.
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.cache.query.continuous
org.apache.ignite.internal.processors.closure: TODO.
org.apache.ignite.internal.processors.cluster
org.apache.ignite.internal.processors.datastreamer: Data streamer processor.
org.apache.ignite.internal.processors.platform
org.apache.ignite.internal.processors.platform.compute
org.apache.ignite.internal.processors.platform.cpp
org.apache.ignite.internal.processors.platform.dotnet
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.lang.gridfunc: Contains utilities classes for `GridFunc`.
org.apache.ignite.internal.util.typedef: Contains typedefs definitions for frequently used classes.
org.apache.ignite.internal.visor.util
org.apache.ignite.lang: Contains general language constructs and functional APIs for distributed computations.

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

Methods in org.apache.ignite with parameters of type IgniteClosure
`<T,R> Collection<R>` IgniteCompute.`apply(IgniteClosure<T,R> job, Collection<? extends T> args)` Executes provided closure job on nodes within the underlying cluster group.
`<R,T> R` IgniteCompute.`apply(IgniteClosure<T,R> job, T arg)` Executes provided closure job on a node within the underlying cluster group.
`<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 the underlying cluster group.
`<T,R> IgniteFuture<Collection<R>>` IgniteCompute.`applyAsync(IgniteClosure<T,R> job, Collection<? extends T> args)` Executes provided closure job asynchronously on nodes within the underlying cluster group.
`<R,T> IgniteFuture<R>` IgniteCompute.`applyAsync(IgniteClosure<T,R> job, T arg)` Executes provided closure job asynchronously on a node within the underlying cluster group.
`<R1,R2,T> IgniteFuture<R2>` IgniteCompute.`applyAsync(IgniteClosure<T,R1> job, Collection<? extends T> args, IgniteReducer<R1,R2> rdc)` Executes provided closure job asynchronously on nodes within the underlying cluster group.
`<R,T> Collection<R>` IgniteCompute.`broadcast(IgniteClosure<T,R> job, T arg)` Broadcasts given closure job with passed in argument to all nodes in the cluster group.
`<R,T> IgniteFuture<Collection<R>>` IgniteCompute.`broadcastAsync(IgniteClosure<T,R> job, T arg)` Broadcasts given closure job asynchronously with passed in argument to all nodes in the cluster group.
`<T,R> QueryCursor<R>` IgniteCache.`query(Query<T> qry, IgniteClosure<T,R> transformer)` Queries the cache transforming the entries on the server nodes.

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

Methods in org.apache.ignite.cache.query that return types with arguments of type IgniteClosure
`javax.cache.configuration.Factory<? extends IgniteClosure<javax.cache.event.CacheEntryEvent<? extends K,? extends V>,T>>` ContinuousQueryWithTransformer.`getRemoteTransformerFactory()` Gets remote transformer factory

Method parameters in org.apache.ignite.cache.query with type arguments of type IgniteClosure
`ContinuousQueryWithTransformer<K,V,T>` ContinuousQueryWithTransformer.`setRemoteTransformerFactory(javax.cache.configuration.Factory<? extends IgniteClosure<javax.cache.event.CacheEntryEvent<? extends K,? extends V>,T>> factory)` Sets transformer factory.

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

Methods in org.apache.ignite.internal with parameters of type IgniteClosure
`void` IgniteKernal.`ackDataRegions(IgniteClosure<String,Void> clo)`
`<T,R> Collection<R>` IgniteComputeImpl.`apply(IgniteClosure<T,R> job, Collection<? extends T> args)` Executes provided closure job on nodes within the underlying cluster group.
`<R,T> R` IgniteComputeImpl.`apply(IgniteClosure<T,R> job, T arg)` Executes provided closure job on a node within the underlying cluster group.
`<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 the underlying cluster group.
`<T,R> IgniteFuture<Collection<R>>` IgniteComputeImpl.`applyAsync(IgniteClosure<T,R> job, Collection<? extends T> args)` Executes provided closure job asynchronously on nodes within the underlying cluster group.
`<R,T> IgniteFuture<R>` IgniteComputeImpl.`applyAsync(IgniteClosure<T,R> job, T arg)` Executes provided closure job asynchronously on a node within the underlying cluster group.
`<R1,R2,T> IgniteFuture<R2>` IgniteComputeImpl.`applyAsync(IgniteClosure<T,R1> job, Collection<? extends T> args, IgniteReducer<R1,R2> rdc)` Executes provided closure job asynchronously on nodes within the underlying cluster group.
`<R,T> Collection<R>` IgniteComputeImpl.`broadcast(IgniteClosure<T,R> job, T arg)` Broadcasts given closure job with passed in argument to all nodes in the cluster group.
`<R,T> IgniteFuture<Collection<R>>` IgniteComputeImpl.`broadcastAsync(IgniteClosure<T,R> job, T arg)` Broadcasts given closure job asynchronously with passed in argument to all nodes in the cluster group.
`<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.
`<T> IgniteInternalFuture<T>` IgniteInternalFuture.`chain(IgniteClosure<? super IgniteInternalFuture<R>,T> doneCb, Executor exec)` Make a chained future to convert result of this future (when complete) into a new format.
`static IgniteDiagnosticMessage` IgniteDiagnosticMessage.`createRequest(Marshaller marsh, IgniteClosure<GridKernalContext,IgniteDiagnosticInfo> c, long futId)`

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

Fields in org.apache.ignite.internal.processors.cache declared as IgniteClosure
`protected static IgniteClosure` GridCacheAdapter.`RET2NULL` `GridCacheReturn`-to-null conversion.

Methods in org.apache.ignite.internal.processors.cache that return IgniteClosure
`static IgniteClosure<GridCacheEntryEx,KeyCacheObject>` 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>` GridCacheUtils.`info2Key()`
`static IgniteClosure<IgniteInternalTx,GridCacheVersion>` GridCacheUtils.`tx2xidVersion()`

Methods in org.apache.ignite.internal.processors.cache with parameters of type IgniteClosure
`<T> IgniteFuture<T>` IgniteCacheFutureImpl.`chain(IgniteClosure<? super IgniteFuture<V>,T> doneCb)` Make a chained future to convert result of this future (when complete) into a new format.
`<T> IgniteFuture<T>` IgniteCacheFutureImpl.`chainAsync(IgniteClosure<? super IgniteFuture<V>,T> doneCb, Executor exec)` Make a chained future to convert result of this future (when complete) into a new format.
`<T,R> QueryCursor<R>` IgniteCacheProxyImpl.`query(Query<T> qry, IgniteClosure<T,R> transformer)` Queries the cache transforming the entries on the server nodes.
`<T,R> QueryCursor<R>` GatewayProtectedCacheProxy.`query(Query<T> qry, IgniteClosure<T,R> transformer)` Queries the cache transforming the entries on the server nodes.

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
`IgniteClosure<?,?>` GridCacheQueryBean.`transform()`
`<K,V> IgniteClosure<Map.Entry<K,V>,Object>` GridCacheQueryAdapter.`transform()`
`IgniteClosure<?,?>` GridCacheQueryRequest.`transformer()`

Methods in org.apache.ignite.internal.processors.cache.query with parameters of type IgniteClosure
`<T,R> CacheQuery<R>` GridCacheQueryManager.`createScanQuery(IgniteBiPredicate<K,V> filter, IgniteClosure<T,R> trans, Integer part, boolean keepBinary, boolean forceLocal)` Creates user's predicate based scan query.

Constructors in org.apache.ignite.internal.processors.cache.query with parameters of type IgniteClosure
Constructor and Description
`GridCacheQueryAdapter(GridCacheContext<?,?> cctx, GridCacheQueryType type, IgniteBiPredicate<Object,Object> filter, IgniteClosure<Map.Entry,Object> transform, Integer part, boolean keepBinary, boolean forceLocal)`
`GridCacheQueryBean(GridCacheQueryAdapter<?> qry, IgniteReducer<Object,Object> rdc, IgniteClosure<?,?> trans, Object[] args)`

`GridCacheQueryRequest(int cacheId, long id, String cacheName, GridCacheQueryType type, boolean fields, String clause, String clsName, IgniteBiPredicate<Object,Object> keyValFilter, Integer part, IgniteReducer<Object,Object> rdc, IgniteClosure<?,?> trans, int pageSize, boolean incBackups, Object[] args, boolean incMeta, boolean keepBinary, UUID subjId, int taskHash, AffinityTopologyVersion topVer, MvccSnapshot mvccSnapshot, boolean addDepInfo)`

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

Methods in org.apache.ignite.internal.processors.cache.query.continuous that return IgniteClosure
`protected IgniteClosure<javax.cache.event.CacheEntryEvent<? extends K,? extends V>,?>` CacheContinuousQueryHandler.`getTransformer()`
`protected IgniteClosure<javax.cache.event.CacheEntryEvent<? extends K,? extends V>,?>` CacheContinuousQueryHandlerV3.`getTransformer()`

Method parameters in org.apache.ignite.internal.processors.cache.query.continuous with type arguments of type IgniteClosure

`UUID`

CacheContinuousQueryManager.`executeQuery(javax.cache.event.CacheEntryUpdatedListener locLsnr, ContinuousQueryWithTransformer.EventListener locTransLsnr, CacheEntryEventSerializableFilter rmtFilter, javax.cache.configuration.Factory<? extends javax.cache.event.CacheEntryEventFilter> rmtFilterFactory, javax.cache.configuration.Factory<? extends IgniteClosure> rmtTransFactory, int bufSize, long timeInterval, boolean autoUnsubscribe, boolean loc, boolean keepBinary, boolean includeExpired)`

Constructor parameters in org.apache.ignite.internal.processors.cache.query.continuous with type arguments of type IgniteClosure
Constructor and Description

`CacheContinuousQueryHandlerV3(String cacheName, Object topic, ContinuousQueryWithTransformer.EventListener<?> locTransLsnr, javax.cache.configuration.Factory<? extends javax.cache.event.CacheEntryEventFilter<K,V>> rmtFilterFactory, javax.cache.configuration.Factory<? extends IgniteClosure<javax.cache.event.CacheEntryEvent<? extends K,? extends V>,?>> rmtTransFactory, boolean oldValRequired, boolean sync, boolean ignoreExpired, boolean ignoreClsNotFound)`

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

Fields in org.apache.ignite.internal.processors.closure declared as IgniteClosure
`protected IgniteClosure<T,R>` GridClosureProcessor.C1.`job`

Methods in org.apache.ignite.internal.processors.closure that return IgniteClosure
`IgniteClosure` GridClosureProcessor.C1.`userObject()` Get user object where resources must be injected.

Methods in org.apache.ignite.internal.processors.closure with parameters of type IgniteClosure
`<T,R> IgniteInternalFuture<Collection<R>>` GridClosureProcessor.`broadcast(IgniteClosure<T,R> job, T arg, Collection<ClusterNode> nodes, String execName)`
`<T,R> ComputeTaskInternalFuture<Collection<R>>` GridClosureProcessor.`callAsync(IgniteClosure<T,R> job, Collection<? extends T> args, Collection<ClusterNode> nodes, String execName)`
`<T,R> ComputeTaskInternalFuture<R>` GridClosureProcessor.`callAsync(IgniteClosure<T,R> job, T arg, Collection<ClusterNode> nodes, String execName)`
`<T,R1,R2> ComputeTaskInternalFuture<R2>` GridClosureProcessor.`callAsync(IgniteClosure<T,R1> job, Collection<? extends T> args, IgniteReducer<R1,R2> rdc, Collection<ClusterNode> nodes, String execName)`

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

Methods in org.apache.ignite.internal.processors.cluster with parameters of type IgniteClosure
`IgniteInternalFuture<String>` ClusterProcessor.`requestDiagnosticInfo(UUID nodeId, IgniteClosure<GridKernalContext,IgniteDiagnosticInfo> c, String baseMsg)` Sends diagnostic message closure to remote node.

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

Methods in org.apache.ignite.internal.processors.datastreamer with parameters of type IgniteClosure
`static byte` DataStreamProcessor.`ioPolicy(IgniteClosure<ClusterNode,Byte> rslvr, ClusterNode node)` Get IO policy for particular node with provided resolver.
`void` DataStreamerImpl.`ioPolicyResolver(IgniteClosure<ClusterNode,Byte> ioPlcRslvr)`

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

Classes in org.apache.ignite.internal.processors.platform that implement IgniteClosure
`class` `PlatformAbstractConfigurationClosure` Abstract interop configuration closure.

Methods in org.apache.ignite.internal.processors.platform that return IgniteClosure
`protected abstract IgniteClosure<IgniteConfiguration,IgniteConfiguration>` PlatformAbstractBootstrap.`closure(long envPtr)` Get configuration transformer closure.

### Uses of IgniteClosure in org.apache.ignite.internal.processors.platform.compute

Methods in org.apache.ignite.internal.processors.platform.compute with parameters of type IgniteClosure
`IgniteInternalFuture` PlatformCompute.ComputeConvertingFuture.`chain(IgniteClosure doneCb)` Make a chained future to convert result of this future (when complete) into a new format.
`IgniteInternalFuture` PlatformCompute.ComputeConvertingFuture.`chain(IgniteClosure doneCb, Executor exec)` Make a chained future to convert result of this future (when complete) into a new format.

### Uses of IgniteClosure in org.apache.ignite.internal.processors.platform.cpp

Classes in org.apache.ignite.internal.processors.platform.cpp that implement IgniteClosure
`class` `PlatformCppConfigurationClosure` Interop CPP configuration closure.

### Uses of IgniteClosure in org.apache.ignite.internal.processors.platform.dotnet

Classes in org.apache.ignite.internal.processors.platform.dotnet that implement IgniteClosure
`class` `PlatformDotNetConfigurationClosure` Closure to apply dot net configuration.

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

Methods in org.apache.ignite.internal.util that return IgniteClosure
`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
`<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>` GridFutureAdapter.`chain(IgniteClosure<? super IgniteInternalFuture<R>,T> doneCb, Executor exec)` 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.
`<T1> IgniteInternalFuture<T1>` GridFinishedFuture.`chain(IgniteClosure<? super IgniteInternalFuture<T>,T1> doneCb, Executor exec)` Make a chained future to convert result of this future (when complete) into a new format.
`<T> IgniteFuture<T>` IgniteFutureImpl.`chainAsync(IgniteClosure<? super IgniteFuture<V>,T> doneCb, Executor exec)` Make a chained future to convert result of this future (when complete) into a new format.
`protected <T> IgniteInternalFuture<T>` IgniteFutureImpl.`chainInternal(IgniteClosure<? super IgniteFuture<V>,T> doneCb, Executor exec)`

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

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

Methods in org.apache.ignite.internal.util.lang that return IgniteClosure
`static <K,V> IgniteClosure<javax.cache.Cache.Entry<K,V>,V>` GridFunc.`cacheEntry2Get()` Gets closure that returns value for an entry.
`static <T> IgniteClosure<T,T>` GridFunc.`identity()` Gets identity closure, i.e. the closure that returns its variable value.
`static IgniteClosure<ClusterNode,UUID>` GridFunc.`node2id()` Gets closure which converts node to node ID.
`static <T> IgniteClosure<T,String>` GridFunc.`string()` Deprecated.

Methods in org.apache.ignite.internal.util.lang with parameters of type IgniteClosure
`static <V,Y> Y` GridFunc.`find(Iterable<? extends V> c, Y dfltVal, IgniteClosure<? super V,Y> f, IgnitePredicate<? super V>... p)` Deprecated.
`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(X[] c, IgniteClosure<? super X,Y> f)` Deprecated.
`static <T1,T2> List<T2>` GridFunc.`transformList(Collection<? extends T1> c, IgniteClosure<? super T1,T2> trans, IgnitePredicate<? super T1>... p)` Deprecated.
`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> 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.

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

Classes in org.apache.ignite.internal.util.lang.gridfunc that implement IgniteClosure
`class` `CacheEntryGetValueClosure` Cache entry to get-value transformer closure.
`class` `ClusterNodeGetIdClosure` Grid node to node ID transformer closure.
`class` `IdentityClosure` Identity closure.
`class` `ToStringClosure<T>` Closure that return `toString()` value for its free variable.

Constructors in org.apache.ignite.internal.util.lang.gridfunc with parameters of type IgniteClosure
Constructor and Description
`PredicateSetView(Set<K> set, IgniteClosure<? super K,V> clo, IgnitePredicate<? super K>... preds)`
`TransformCollectionView(Collection<? extends T2> col, IgniteClosure<? super T2,T1> clos, IgnitePredicate<? super T2>... preds)`
`TransformFilteringIterator(Iterator<? extends T1> iter, IgniteClosure<? super T1,T2> clos, boolean readOnly, IgnitePredicate<? super T1>... preds)`
`TransformMapView(Map<K,V> map, IgniteClosure<V,V1> clos, IgnitePredicate<? super K>... preds)`

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

Subinterfaces of IgniteClosure in org.apache.ignite.internal.util.typedef
`interface` `C1<E1,R>` Defines `alias` for `IgniteClosure` by extending it.

Classes in org.apache.ignite.internal.util.typedef that implement IgniteClosure
`class` `CX1<E1,R>` Defines `alias` for `IgniteClosureX` by extending it.

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

Classes in org.apache.ignite.internal.visor.util that implement IgniteClosure
`class` `VisorEventMapper` Mapper from grid event to Visor data transfer object.

Methods in org.apache.ignite.internal.visor.util with parameters of type IgniteClosure
`static Collection<VisorGridEvent>` VisorTaskUtils.`collectEvents(Ignite ignite, String evtOrderKey, String evtThrottleCntrKey, boolean all, IgniteClosure<Event,VisorGridEvent> evtMapper)` Grabs local events and detects if events was lost since last poll.
`static List<VisorGridEvent>` VisorTaskUtils.`collectEvents(Ignite ignite, String evtOrderKey, String evtThrottleCntrKey, int[] evtTypes, IgniteClosure<Event,VisorGridEvent> evtMapper)` Grabs local events and detects if events was lost since last poll.

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

Methods in org.apache.ignite.lang with parameters of type IgniteClosure
`<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.
`<T> IgniteFuture<T>` IgniteFuture.`chainAsync(IgniteClosure<? super IgniteFuture<V>,T> doneCb, Executor exec)` Make a chained future to convert result of this future (when complete) into a new format.

2018 Copyright © Apache Software Foundation

Follow @ApacheIgnite

Ignite Database and Caching Platform | : ver. 2.7.0
Release Date | : November 30 2018